Package 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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
AbstractNioBossPool(Executor bossExecutor, int bossCount)	Create a new instance
AbstractNioBossPool(Executor bossExecutor, int bossCount, boolean autoInit)

Method Summary

Modifier and Type	Method	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
private void	waitForBossThreads()

Methods inherited from class java.lang.Object

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

Field Details

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 AtomicInteger bossIndex

bossExecutor

private final Executor bossExecutor

initialized

private final AtomicBoolean initialized

Constructor Details

AbstractNioBossPool

AbstractNioBossPool(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(Executor bossExecutor,
 int bossCount,
 boolean autoInit)

Method Details

init

protected void init()

waitForBossThreads

private void waitForBossThreads()

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