org.apache.geronimo.connector.work.pool

Class WorkExecutorPoolImpl

java.lang.Object

org.apache.geronimo.connector.work.pool.WorkExecutorPoolImpl

All Implemented Interfaces:

Executor, WorkExecutorPool

public class WorkExecutorPoolImpl
extends Object
implements WorkExecutorPool

Based class for WorkExecutorPool. Sub-classes define the synchronization policy (should the call block until the end of the work; or when it starts et cetera).

Version:

$Rev$ $Date$

Constructor Summary

Constructors

Constructor and Description
WorkExecutorPoolImpl(int maxSize) Creates a pool with the specified minimum and maximum sizes.

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable work) Execute the specified Work.
int	getMaximumPoolSize() Gets the maximum size of this pool.
int	getPoolSize() Gets the size of this pool.
void	setMaximumPoolSize(int maxSize) Sets the maximum size of this pool.
WorkExecutorPool	start()
WorkExecutorPool	stop() Stops this pool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkExecutorPoolImpl

public WorkExecutorPoolImpl(int maxSize)

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.

Method Detail

execute

public void execute(Runnable work)

Execute the specified Work.

Specified by:

execute in interface Executor

Parameters:

work - Work to be executed.

getPoolSize

public int getPoolSize()

Gets the size of this pool.

Specified by:

getPoolSize in interface WorkExecutorPool

Returns:

Number of active threads in the pool.

getMaximumPoolSize

public int getMaximumPoolSize()

Gets the maximum size of this pool.

Specified by:

getMaximumPoolSize in interface WorkExecutorPool

Returns:

Maximum size.

setMaximumPoolSize

public void setMaximumPoolSize(int maxSize)

Sets the maximum size of this pool.

Specified by:

setMaximumPoolSize in interface WorkExecutorPool

Parameters:

maxSize - New maximum size of this pool.

start

public WorkExecutorPool start()

Specified by:

start in interface WorkExecutorPool

stop

public WorkExecutorPool stop()

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

Specified by:

stop in interface WorkExecutorPool