org.jboss.netty.channel.socket.nio

Class ShareableWorkerPool<E extends Worker>

java.lang.Object

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

All Implemented Interfaces:

NioSelectorPool, WorkerPool<E>

public final class ShareableWorkerPool<E extends Worker>
extends Object
implements WorkerPool<E>

This implementation of a WorkerPool should be used if you plan to share a WorkerPool between different Factories. You will need to call destroy() by your own once you want to release any resources of it.

Constructor Summary

Constructors

Constructor and Description
ShareableWorkerPool(WorkerPool<E> wrapped)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the ShareableWorkerPool and release all resources.
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	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

Constructor Detail

ShareableWorkerPool

public ShareableWorkerPool(WorkerPool<E> wrapped)

Method Detail

nextWorker

public E nextWorker()

Description copied from interface: WorkerPool

Return the next Worker to use

Specified by:

nextWorker in interface WorkerPool<E extends Worker>

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

destroy

public void destroy()

Destroy the ShareableWorkerPool and release all resources. After this is called its not usable anymore

shutdown

public void shutdown()

Description copied from interface: NioSelectorPool

Shutdown the NioSelectorPool and all internal created resources

Specified by:

shutdown in interface NioSelectorPool