| Package | Description |
|---|---|
| org.jboss.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractNioWorkerPool<E extends AbstractNioWorker>
Abstract base class for
WorkerPool implementations that create the Worker's
up-front and return them in a "fair" fashion when calling AbstractNioWorkerPool.nextWorker() |
class |
NioDatagramWorkerPool
Default implementation which hands of
NioDatagramWorker's |
class |
NioWorkerPool
Default implementation which hands of
NioWorker's |
class |
ShareableWorkerPool<E extends Worker>
This implementation of a
WorkerPool should be used if you plan to share a
WorkerPool between different Factories. |
| Modifier and Type | Field and Description |
|---|---|
private WorkerPool<NioWorker> |
NioClientSocketChannelFactory.workerPool |
private WorkerPool<NioDatagramWorker> |
NioDatagramChannelFactory.workerPool |
private WorkerPool<NioDatagramWorker> |
NioDatagramPipelineSink.workerPool |
(package private) WorkerPool<NioWorker> |
NioServerSocketChannel.workerPool |
private WorkerPool<NioWorker> |
NioServerSocketChannelFactory.workerPool |
private WorkerPool<E> |
ShareableWorkerPool.wrapped |
| Constructor and Description |
|---|
NioClientSocketChannelFactory(BossPool<NioClientBoss> bossPool,
WorkerPool<NioWorker> workerPool)
Creates a new instance.
|
NioClientSocketChannelFactory(java.util.concurrent.Executor bossExecutor,
int bossCount,
WorkerPool<NioWorker> workerPool)
Creates a new instance.
|
NioClientSocketChannelFactory(java.util.concurrent.Executor bossExecutor,
int bossCount,
WorkerPool<NioWorker> workerPool,
Timer timer)
Creates a new instance.
|
NioDatagramChannelFactory(WorkerPool<NioDatagramWorker> workerPool)
Creates a new instance.
|
NioDatagramChannelFactory(WorkerPool<NioDatagramWorker> workerPool,
InternetProtocolFamily family)
Creates a new instance.
|
NioDatagramPipelineSink(WorkerPool<NioDatagramWorker> workerPool)
Creates a new
NioDatagramPipelineSink with a the number of NioDatagramWorkers
specified in workerCount. |
NioServerSocketChannel(ChannelFactory factory,
ChannelPipeline pipeline,
ChannelSink sink,
Boss boss,
WorkerPool<NioWorker> workerPool) |
NioServerSocketChannelFactory(BossPool<NioServerBoss> bossPool,
WorkerPool<NioWorker> workerPool)
Create a new instance.
|
NioServerSocketChannelFactory(java.util.concurrent.Executor bossExecutor,
int bossCount,
WorkerPool<NioWorker> workerPool)
Create a new instance.
|
NioServerSocketChannelFactory(java.util.concurrent.Executor bossExecutor,
WorkerPool<NioWorker> workerPool)
Creates a new instance.
|
ShareableWorkerPool(WorkerPool<E> wrapped) |