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 java.lang.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.

Field Summary

Fields

Modifier and Type	Field and Description
private WorkerPool<E>	wrapped

Constructor Summary

Constructors

Constructor and Description
ShareableWorkerPool(WorkerPool<E> wrapped)

Method Summary

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

Field Detail

wrapped

private final WorkerPool<E extends Worker> wrapped

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