org.jboss.netty.channel.socket.nio

Class NioClientBossPool

java.lang.Object

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

org.jboss.netty.channel.socket.nio.NioClientBossPool

All Implemented Interfaces:

BossPool<NioClientBoss>, NioSelectorPool, ExternalResourceReleasable

public class NioClientBossPool
extends AbstractNioBossPool<NioClientBoss>

Holds NioClientBoss instances to use

Field Summary

Fields

Modifier and Type	Field and Description
private ThreadNameDeterminer	determiner
private boolean	stopTimer
private Timer	timer

Constructor Summary

Constructors

Constructor and Description
NioClientBossPool(java.util.concurrent.Executor bossExecutor, int bossCount) Create a new instance using a new HashedWheelTimer and no ThreadNameDeterminer
NioClientBossPool(java.util.concurrent.Executor bossExecutor, int bossCount, Timer timer, ThreadNameDeterminer determiner) Create a new instance

Method Summary

Modifier and Type	Method and Description
protected NioClientBoss	newBoss(java.util.concurrent.Executor executor) Create a new Boss which uses the given Executor to service IO
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 org.jboss.netty.channel.socket.nio.AbstractNioBossPool

init, nextBoss, rebuildSelectors

Methods inherited from class java.lang.Object

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

Field Detail

determiner

private final ThreadNameDeterminer determiner

timer

private final Timer timer

stopTimer

private boolean stopTimer

Constructor Detail

NioClientBossPool

public NioClientBossPool(java.util.concurrent.Executor bossExecutor,
                         int bossCount,
                         Timer timer,
                         ThreadNameDeterminer determiner)

Create a new instance

Parameters:

bossExecutor - the Executor to use for server the NioClientBoss

bossCount - the number of NioClientBoss instances this NioClientBossPool will hold

timer - the Timer to use for handle connect timeouts

determiner - the ThreadNameDeterminer to use for name the threads. Use null if you not want to set one explicit.

NioClientBossPool

public NioClientBossPool(java.util.concurrent.Executor bossExecutor,
                         int bossCount)

Create a new instance using a new HashedWheelTimer and no ThreadNameDeterminer

Parameters:

bossExecutor - the Executor to use for server the NioClientBoss

bossCount - the number of NioClientBoss instances this NioClientBoss will hold

Method Detail

newBoss

protected NioClientBoss newBoss(java.util.concurrent.Executor executor)

Description copied from class: AbstractNioBossPool

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

Specified by:

newBoss in class AbstractNioBossPool<NioClientBoss>

Parameters:

executor - the Executor to use

Returns:

worker the new Boss

shutdown

public void shutdown()

Description copied from interface: NioSelectorPool

Shutdown the NioSelectorPool and all internal created resources

Specified by:

shutdown in interface NioSelectorPool

Overrides:

shutdown in class AbstractNioBossPool<NioClientBoss>

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

Overrides:

releaseExternalResources in class AbstractNioBossPool<NioClientBoss>