com.maverick.nio

Class SelectorThreadPool

java.lang.Object

com.maverick.nio.SelectorThreadPool

public class SelectorThreadPool
extends Object

Maintains a pool of SelectoThreads increasing the pool when required and always maintaining the minimum number of permanent threads required.

Author:

Lee David Painter

Constructor Summary

Constructors

Constructor and Description
SelectorThreadPool(SelectorThreadImpl impl, int permanentThreads, int maximumChannels, int idleServicePeriod, int inactivePeriodsPerIdleEvent, SelectorProvider selectorProvider) Construct a thread pool.
SelectorThreadPool(SelectorThreadImpl impl, int permanentThreads, int maximumChannels, int idleServicePeriod, int inactivePeriodsPerIdleEvent, SelectorProvider selectorProvider, int threadPriority)

Method Summary

Modifier and Type	Method and Description
void	closeAllChannels()
int	getCurrentLoad()
boolean	isShuttingDown()
SelectorThread	selectNextThread() Select the next available thread with the minimum load.
void	shutdown() Shutdown all threads in the pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectorThreadPool

public SelectorThreadPool(SelectorThreadImpl impl,
                          int permanentThreads,
                          int maximumChannels,
                          int idleServicePeriod,
                          int inactivePeriodsPerIdleEvent,
                          SelectorProvider selectorProvider)
                   throws IOException

Construct a thread pool. if(log.isDebugEnabled()) log.debug(

Parameters:

impl - SelectorThreadImpl

permanentThreads - int

maximumChannels - int

idleServicePeriod - int

inactivePeriodsPerIdleEvent - int

selectorProvider - SelectorProvider

Throws:

IOException

SelectorThreadPool

public SelectorThreadPool(SelectorThreadImpl impl,
                          int permanentThreads,
                          int maximumChannels,
                          int idleServicePeriod,
                          int inactivePeriodsPerIdleEvent,
                          SelectorProvider selectorProvider,
                          int threadPriority)
                   throws IOException

Throws:

IOException

Method Detail

closeAllChannels

public void closeAllChannels()

shutdown

public void shutdown()

Shutdown all threads in the pool.

isShuttingDown

public boolean isShuttingDown()

getCurrentLoad

public int getCurrentLoad()

selectNextThread

public SelectorThread selectNextThread()
                                throws IOException

Select the next available thread with the minimum load.

Returns:

SelectorThread

Throws:

IOException