| Package | Description |
|---|---|
| org.jboss.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
| org.jboss.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
| org.jboss.netty.util |
Utility classes used across multiple packages.
|
| Modifier and Type | Field and Description |
|---|---|
private ThreadNameDeterminer |
NioClientBossPool.determiner |
private ThreadNameDeterminer |
NioServerBossPool.determiner |
private ThreadNameDeterminer |
NioWorkerPool.determiner |
| Modifier and Type | Method and Description |
|---|---|
protected abstract ThreadRenamingRunnable |
AbstractNioSelector.newThreadRenamingRunnable(int id,
ThreadNameDeterminer determiner) |
protected ThreadRenamingRunnable |
AbstractNioWorker.newThreadRenamingRunnable(int id,
ThreadNameDeterminer determiner) |
protected ThreadRenamingRunnable |
NioClientBoss.newThreadRenamingRunnable(int id,
ThreadNameDeterminer determiner) |
protected ThreadRenamingRunnable |
NioServerBoss.newThreadRenamingRunnable(int id,
ThreadNameDeterminer determiner) |
private void |
AbstractNioSelector.openSelector(ThreadNameDeterminer determiner)
Start the
AbstractNioWorker and return the Selector that will be used for
the AbstractNioChannel's when they get registered |
| Constructor and Description |
|---|
AbstractNioSelector(java.util.concurrent.Executor executor,
ThreadNameDeterminer determiner) |
AbstractNioWorker(java.util.concurrent.Executor executor,
ThreadNameDeterminer determiner) |
NioClientBoss(java.util.concurrent.Executor bossExecutor,
Timer timer,
ThreadNameDeterminer determiner) |
NioClientBossPool(java.util.concurrent.Executor bossExecutor,
int bossCount,
Timer timer,
ThreadNameDeterminer determiner)
Create a new instance
|
NioServerBoss(java.util.concurrent.Executor bossExecutor,
ThreadNameDeterminer determiner) |
NioServerBossPool(java.util.concurrent.Executor bossExecutor,
int bossCount,
ThreadNameDeterminer determiner)
Create a new instance
|
NioWorker(java.util.concurrent.Executor executor,
ThreadNameDeterminer determiner) |
NioWorkerPool(java.util.concurrent.Executor workerExecutor,
int workerCount,
ThreadNameDeterminer determiner) |
| Modifier and Type | Field and Description |
|---|---|
private ThreadNameDeterminer |
OioClientSocketPipelineSink.determiner |
private ThreadNameDeterminer |
OioDatagramPipelineSink.determiner |
private ThreadNameDeterminer |
OioServerSocketPipelineSink.determiner |
| Constructor and Description |
|---|
OioClientSocketChannelFactory(java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner)
Creates a new instance.
|
OioClientSocketPipelineSink(java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner) |
OioDatagramChannelFactory(java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner)
Creates a new instance.
|
OioDatagramPipelineSink(java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner) |
OioServerSocketChannelFactory(java.util.concurrent.Executor bossExecutor,
java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner)
Creates a new instance.
|
OioServerSocketPipelineSink(java.util.concurrent.Executor workerExecutor,
ThreadNameDeterminer determiner) |
| Modifier and Type | Field and Description |
|---|---|
static ThreadNameDeterminer |
ThreadNameDeterminer.CURRENT
ThreadNameDeterminer that rejects the proposed thread name and
retains the current one. |
private ThreadNameDeterminer |
ThreadRenamingRunnable.determiner |
static ThreadNameDeterminer |
ThreadNameDeterminer.PROPOSED
ThreadNameDeterminer that accepts the proposed thread name
as is. |
private static ThreadNameDeterminer |
ThreadRenamingRunnable.threadNameDeterminer |
| Modifier and Type | Method and Description |
|---|---|
static ThreadNameDeterminer |
ThreadRenamingRunnable.getThreadNameDeterminer()
Returns the
ThreadNameDeterminer which overrides the proposed
new thread name. |
| Modifier and Type | Method and Description |
|---|---|
static void |
ThreadRenamingRunnable.setThreadNameDeterminer(ThreadNameDeterminer threadNameDeterminer)
Sets the
ThreadNameDeterminer which overrides the proposed new
thread name. |
| Constructor and Description |
|---|
HashedWheelTimer(java.util.concurrent.ThreadFactory threadFactory,
ThreadNameDeterminer determiner,
long tickDuration,
java.util.concurrent.TimeUnit unit,
int ticksPerWheel)
Creates a new timer.
|
ThreadRenamingRunnable(java.lang.Runnable runnable,
java.lang.String proposedThreadName,
ThreadNameDeterminer determiner)
Creates a new instance which wraps the specified
runnable
and changes the thread name to the specified thread name when the
specified runnable is running. |