/*
 * Copyright Terracotta, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.ehcache.impl.config.executor;

import java.util.HashMap;
import java.util.Map;

import org.ehcache.config.builders.PooledExecutionServiceConfigurationBuilder;
import org.ehcache.core.spi.service.ExecutionService;
import org.ehcache.spi.service.ServiceCreationConfiguration;

import static java.util.Collections.unmodifiableMap;
import static org.ehcache.config.builders.PooledExecutionServiceConfigurationBuilder.newPooledExecutionServiceConfigurationBuilder;

ServiceCreationConfiguration for the pooled ExecutionService implementation. 

Enables configuring named thread pools that can then be used by the different Ehcache services
that require threads to function.
See Also:
CacheEventDispatcherFactoryConfiguration
DefaultCacheEventDispatcherConfiguration
WriteBehindProviderConfiguration
DefaultWriteBehindConfiguration
OffHeapDiskStoreProviderConfiguration
OffHeapDiskStoreConfiguration/**
 * {@link ServiceCreationConfiguration} for the pooled {@link ExecutionService} implementation.
 * <p>
 * Enables configuring named thread pools that can then be used by the different Ehcache services
 * that require threads to function.
 *
 * @see org.ehcache.impl.config.event.CacheEventDispatcherFactoryConfiguration
 * @see org.ehcache.impl.config.event.DefaultCacheEventDispatcherConfiguration
 * @see org.ehcache.impl.config.loaderwriter.writebehind.WriteBehindProviderConfiguration
 * @see org.ehcache.impl.config.loaderwriter.writebehind.DefaultWriteBehindConfiguration
 * @see org.ehcache.impl.config.store.disk.OffHeapDiskStoreProviderConfiguration
 * @see org.ehcache.impl.config.store.disk.OffHeapDiskStoreConfiguration
 */
public class PooledExecutionServiceConfiguration implements ServiceCreationConfiguration<ExecutionService, PooledExecutionServiceConfigurationBuilder> {

  private final Map<String, PoolConfiguration> poolConfigurations = new HashMap<>();

  private String defaultAlias;

  
Adds a new default pool with the provided minimum and maximum.

The default pool will be used by any service requiring threads but not specifying a pool alias.
It is not mandatory to have a default pool.
But without one ALL services have to specify a pool alias.
Params:
alias – the pool alias
minSize – the minimum size
maxSize – the maximum size
Throws:
NullPointerException – if alias is null
IllegalArgumentException – if another default was configured already or if another pool with the same
                                 alias was configured already
Returns:
this configuration object with a new default pool/**
   * Adds a new default pool with the provided minimum and maximum.
   * <p>
   * The default pool will be used by any service requiring threads but not specifying a pool alias.
   * It is not mandatory to have a default pool.
   * But without one <i>ALL</i> services have to specify a pool alias.
   *
   * @param alias the pool alias
   * @param minSize the minimum size
   * @param maxSize the maximum size
   * @return this configuration object with a new default pool
   *
   * @throws NullPointerException if alias is null
   * @throws IllegalArgumentException if another default was configured already or if another pool with the same
   *                                  alias was configured already
   */
  public PooledExecutionServiceConfiguration addDefaultPool(String alias, int minSize, int maxSize) {
    if (alias == null) {
      throw new NullPointerException("Pool alias cannot be null");
    }
    if (defaultAlias == null) {
      addPool(alias, minSize, maxSize);
      defaultAlias = alias;
      return this;
    } else {
      throw new IllegalArgumentException("'" + defaultAlias + "' is already configured as the default pool");
    }
  }

  
Adds a new pool with the provided minimum and maximum.
Params:
alias – the pool alias
minSize – the minimum size
maxSize – the maximum size
Throws:
NullPointerException – if alias is null
IllegalArgumentException – if another pool with the same alias was configured already
Returns:
this configuration object with a new pool/**
   * Adds a new pool with the provided minimum and maximum.
   *
   * @param alias the pool alias
   * @param minSize the minimum size
   * @param maxSize the maximum size
   * @return this configuration object with a new pool
   *
   * @throws NullPointerException if alias is null
   * @throws IllegalArgumentException if another pool with the same alias was configured already
   */
  public PooledExecutionServiceConfiguration addPool(String alias, int minSize, int maxSize) {
    if (alias == null) {
      throw new NullPointerException("Pool alias cannot be null");
    }
    if (poolConfigurations.containsKey(alias)) {
      throw new IllegalArgumentException("A pool with the alias '" + alias + "' is already configured");
    } else {
      poolConfigurations.put(alias, new PoolConfiguration(minSize, maxSize));
      return this;
    }
  }

  
Returns the map from alias to PoolConfiguration defined by this configuration object. 
Returns:
a map from alias to pool configuration/**
   * Returns the map from alias to {@link PoolConfiguration} defined by this configuration object.
   *
   * @return a map from alias to pool configuration
   */
  public Map<String, PoolConfiguration> getPoolConfigurations() {
    return unmodifiableMap(poolConfigurations);
  }

  
Returns the default pool alias, or null if none configured. 
Returns:
the default pool alias or null/**
   * Returns the default pool alias, or {@code null} if none configured.
   *
   * @return the default pool alias or {@code null}
   */
  public String getDefaultPoolAlias() {
    return defaultAlias;
  }

  
{@inheritDoc}
/**
   * {@inheritDoc}
   */
  @Override
  public Class<ExecutionService> getServiceType() {
    return ExecutionService.class;
  }

  @Override
  public PooledExecutionServiceConfigurationBuilder derive() {
    return newPooledExecutionServiceConfigurationBuilder(this);
  }

  @Override
  public PooledExecutionServiceConfiguration build(PooledExecutionServiceConfigurationBuilder builder) {
    return builder.build();
  }

  
Configuration class representing a pool configuration.
/**
   * Configuration class representing a pool configuration.
   */
  public static final class PoolConfiguration {

    private final int minSize;
    private final int maxSize;

    private PoolConfiguration(int minSize, int maxSize) {
      this.minSize = minSize;
      this.maxSize = maxSize;
    }

    
Returns the minimum size of the pool.
Returns:
the minimum size/**
     * Returns the minimum size of the pool.
     *
     * @return the minimum size
     */
    public int minSize() {
      return minSize;
    }

    
Returns the maximum size of the pool.
Returns:
the maximum size/**
     * Returns the maximum size of the pool.
     *
     * @return the maximum size
     */
    public int maxSize() {
      return maxSize;
    }
  }
}