org.jboss.netty.channel.socket.nio

Class AbstractNioBossPool<E extends Boss>

java.lang.Object

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

All Implemented Interfaces:

BossPool<E>, NioSelectorPool, ExternalResourceReleasable

Direct Known Subclasses:

NioClientBossPool, NioServerBossPool

public abstract class AbstractNioBossPool<E extends Boss>
extends Object
implements BossPool<E>, ExternalResourceReleasable

Method Summary

Methods

Modifier and Type	Method and Description
protected void	init()
protected abstract E	newBoss(Executor executor) Create a new Boss which uses the given Executor to service IO
E	nextBoss() Return the next Boss 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 Detail

init

protected void init()

newBoss

protected abstract E newBoss(Executor executor)

Create a new Boss which uses the given Executor to service IO

Parameters:

executor - the Executor to use

Returns:

worker the new Boss

nextBoss

public E nextBoss()

Description copied from interface: BossPool

Return the next Boss to use

Specified by:

nextBoss in interface BossPool<E extends Boss>

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