Package org.jboss.netty.channel.socket.nio

Class AbstractNioWorkerPool<E extends org.jboss.netty.channel.socket.nio.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 org.jboss.netty.channel.socket.nio.AbstractNioWorker>
extends 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()

Method Summary

Modifier and Type	Method	Description
protected void	init()
protected abstract E	newWorker(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

Methods inherited from class java.lang.Object

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

Method Details

init

protected void init()

newWorker

protected abstract E newWorker(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 org.jboss.netty.channel.socket.nio.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