org.jboss.netty.channel.socket.nio

Class AbstractNioWorkerPool<E extends AbstractNioWorker>

java.lang.Object

org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool<E>

All Implemented Interfaces:

NioSelectorPool, WorkerPool<E>, ExternalResourceReleasable

Direct Known Subclasses:

NioDatagramWorkerPool, NioWorkerPool

public abstract class AbstractNioWorkerPool<E extends AbstractNioWorker>
extends java.lang.Object
implements WorkerPool<E>, ExternalResourceReleasable

Abstract base class for WorkerPool implementations that create the Worker's up-front and return them in a "fair" fashion when calling nextWorker()

Field Summary

Fields

Modifier and Type	Field and Description
private static int	INITIALIZATION_TIMEOUT The worker pool raises an exception unless all worker threads start and run within this timeout (in seconds.)
private java.util.concurrent.atomic.AtomicBoolean	initialized
private static InternalLogger	logger
private java.util.concurrent.Executor	workerExecutor
private java.util.concurrent.atomic.AtomicInteger	workerIndex
private AbstractNioWorker[]	workers

Constructor Summary

Constructors

Constructor and Description
AbstractNioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount) Create a new instance
AbstractNioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount, boolean autoInit)

Method Summary

Modifier and Type	Method and Description
protected void	init()
protected abstract E	newWorker(java.util.concurrent.Executor executor) Create a new Worker which uses the given Executor to service IO.
E	nextWorker() Return the next Worker to use
void	rebuildSelectors() Replaces the current Selectors of the Bosses with new Selectors to work around the infamous epoll 100% CPU bug.
void	releaseExternalResources() Releases the external resources that this object depends on.
void	shutdown() Shutdown the NioSelectorPool and all internal created resources
private void	waitForWorkerThreads()

Methods inherited from class java.lang.Object

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

Field Detail

INITIALIZATION_TIMEOUT

private static final int INITIALIZATION_TIMEOUT

The worker pool raises an exception unless all worker threads start and run within this timeout (in seconds.)

See Also:

Constant Field Values

logger

private static final InternalLogger logger

workers

private final AbstractNioWorker[] workers

workerIndex

private final java.util.concurrent.atomic.AtomicInteger workerIndex

workerExecutor

private final java.util.concurrent.Executor workerExecutor

initialized

private final java.util.concurrent.atomic.AtomicBoolean initialized

Constructor Detail

AbstractNioWorkerPool

AbstractNioWorkerPool(java.util.concurrent.Executor workerExecutor,
                      int workerCount)

Create a new instance

Parameters:

workerExecutor - the Executor to use for the Worker's

workerCount - the count of Worker's to create

AbstractNioWorkerPool

AbstractNioWorkerPool(java.util.concurrent.Executor workerExecutor,
                      int workerCount,
                      boolean autoInit)

Method Detail

init

protected void init()

waitForWorkerThreads

private void waitForWorkerThreads()

newWorker

protected abstract E newWorker(java.util.concurrent.Executor executor)

Create a new Worker which uses the given Executor to service IO.

Parameters:

executor - the Executor to use

Returns:

worker the new Worker

nextWorker

public E nextWorker()

Description copied from interface: WorkerPool

Return the next Worker to use

Specified by:

nextWorker in interface WorkerPool<E extends AbstractNioWorker>

Returns:

worker

rebuildSelectors

public void rebuildSelectors()

Description copied from interface: NioSelectorPool

Replaces the current Selectors of the Bosses with new Selectors to work around the infamous epoll 100% CPU bug.

Specified by:

rebuildSelectors in interface NioSelectorPool

releaseExternalResources

public void releaseExternalResources()

Description copied from interface: ExternalResourceReleasable

Releases the external resources that this object depends on. You should not call this method if the external resources (e.g. thread pool) are in use by other objects.

Specified by:

releaseExternalResources in interface ExternalResourceReleasable

shutdown

public void shutdown()

Description copied from interface: NioSelectorPool

Shutdown the NioSelectorPool and all internal created resources

Specified by:

shutdown in interface NioSelectorPool