public WorkExecutorPoolImpl(int maxSize) 
{
        pooledExecutor = new PooledExecutor(new LinkedQueue(), maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
}

Creates a pool with the specified minimum and maximum sizes. The Channel used to enqueue the submitted Work instances is queueless synchronous one.

Parameters:

maxSize - Maximum size of the work executor pool.

 public WorkExecutorPoolImpl(Channel channel,
    int maxSize) 
{
        pooledExecutor = new PooledExecutor(channel, maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
}

Creates a pool with the specified minimum and maximum sizes and using the specified Channel to enqueue the submitted Work instances.

Parameters:

channel - Queue to be used as the queueing facility of this pool.

maxSize - Maximum size of the work executor pool.

 public  void execute(Runnable work) throws InterruptedException 
{
        pooledExecutor.execute(work);
}

Execute the specified Work.

 public int getMaximumPoolSize() 
{
        return pooledExecutor.getMaximumPoolSize();
}

Gets the maximum size of this pool.

 public int getPoolSize() 
{
        return pooledExecutor.getPoolSize();
}

Gets the size of this pool.

 public  void setMaximumPoolSize(int maxSize) 
{
        pooledExecutor.setMaximumPoolSize(maxSize);
}

Sets the maximum size of this pool.

 public WorkExecutorPool start() 
{
        throw new IllegalStateException("This pooled executor is already started");
}

 public WorkExecutorPool stop() 
{
        int maxSize = getMaximumPoolSize();
        pooledExecutor.shutdownAfterProcessingCurrentlyQueuedTasks();
        return new NullWorkExecutorPool(maxSize);
}

Stops this pool. Prior to stop this pool, all the enqueued Work instances are processed. This is an orderly shutdown.