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 java.lang.Object
implements BossPool<E>, ExternalResourceReleasable

Field Summary

Fields

Modifier and Type	Field and Description
private Boss[]	bosses
private java.util.concurrent.Executor	bossExecutor
private java.util.concurrent.atomic.AtomicInteger	bossIndex
private static int	INITIALIZATION_TIMEOUT The boss pool raises an exception unless all boss threads start and run within this timeout (in seconds.)
private java.util.concurrent.atomic.AtomicBoolean	initialized
private static InternalLogger	logger

Constructor Summary

Constructors

Constructor and Description
AbstractNioBossPool(java.util.concurrent.Executor bossExecutor, int bossCount) Create a new instance
AbstractNioBossPool(java.util.concurrent.Executor bossExecutor, int bossCount, boolean autoInit)

Method Summary

Modifier and Type	Method and Description
protected void	init()
protected abstract E	newBoss(java.util.concurrent.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
private void	waitForBossThreads()

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 boss pool raises an exception unless all boss threads start and run within this timeout (in seconds.)

See Also:

Constant Field Values

logger

private static final InternalLogger logger

bosses

private final Boss[] bosses

bossIndex

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

bossExecutor

private final java.util.concurrent.Executor bossExecutor

initialized

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

Constructor Detail

AbstractNioBossPool

AbstractNioBossPool(java.util.concurrent.Executor bossExecutor,
                    int bossCount)

Create a new instance

Parameters:

bossExecutor - the Executor to use for the Boss's

bossCount - the count of Boss's to create

AbstractNioBossPool

AbstractNioBossPool(java.util.concurrent.Executor bossExecutor,
                    int bossCount,
                    boolean autoInit)

Method Detail

init

protected void init()

waitForBossThreads

private void waitForBossThreads()

newBoss

protected abstract E newBoss(java.util.concurrent.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