Class NioWorkerPool
- java.lang.Object
-
- org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool<NioWorker>
-
- org.jboss.netty.channel.socket.nio.NioWorkerPool
-
- All Implemented Interfaces:
NioSelectorPool
,WorkerPool<NioWorker>
,ExternalResourceReleasable
public class NioWorkerPool extends AbstractNioWorkerPool<NioWorker>
Default implementation which hands ofNioWorker
's
-
-
Field Summary
Fields Modifier and Type Field Description private ThreadNameDeterminer
determiner
-
Constructor Summary
Constructors Constructor Description NioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount)
NioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount, ThreadNameDeterminer determiner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected NioWorker
newWorker(java.util.concurrent.Executor executor)
Create a newWorker
which uses the givenExecutor
to service IO.-
Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioWorkerPool
init, nextWorker, rebuildSelectors, releaseExternalResources, shutdown
-
-
-
-
Field Detail
-
determiner
private final ThreadNameDeterminer determiner
-
-
Constructor Detail
-
NioWorkerPool
public NioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount)
-
NioWorkerPool
public NioWorkerPool(java.util.concurrent.Executor workerExecutor, int workerCount, ThreadNameDeterminer determiner)
-
-
Method Detail
-
newWorker
protected NioWorker newWorker(java.util.concurrent.Executor executor)
Description copied from class:AbstractNioWorkerPool
Create a newWorker
which uses the givenExecutor
to service IO.- Specified by:
newWorker
in classAbstractNioWorkerPool<NioWorker>
- Parameters:
executor
- theExecutor
to use- Returns:
- worker the new
Worker
-
-