Modifier and Type | Field and Description |
---|---|
protected static InternalLogger |
logger
Internal Netty logger.
|
protected Selector |
selector
The NIO
Selector . |
protected Thread |
thread
If this worker has been started thread will be a reference to the thread
used when starting. i.e. the current thread when the run method is executed.
|
protected AtomicBoolean |
wakenUp
Boolean that controls determines if a blocked Selector.select should
break out of its selection process.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
cleanUpCancelledKeys() |
protected void |
close(SelectionKey k) |
protected Runnable |
createRegisterTask(Channel channel,
ChannelFuture future) |
protected void |
increaseCancelledKeys() |
protected boolean |
isIoThread() |
protected ThreadRenamingRunnable |
newThreadRenamingRunnable(int id,
ThreadNameDeterminer determiner) |
protected void |
process(Selector selector) |
void |
rebuildSelector()
|
void |
register(Channel channel,
ChannelFuture future) |
protected void |
registerTask(Runnable task) |
void |
run() |
protected int |
select(Selector selector) |
void |
shutdown() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
rebuildSelector, register, shutdown
protected static final InternalLogger logger
protected volatile Thread thread
protected final AtomicBoolean wakenUp
protected ThreadRenamingRunnable newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected Runnable createRegisterTask(Channel channel, ChannelFuture future)
protected void process(Selector selector)
protected void close(SelectionKey k)
public void register(Channel channel, ChannelFuture future)
register
in interface NioSelector
protected final void registerTask(Runnable task)
protected final boolean isIoThread()
public void rebuildSelector()
NioSelector
rebuildSelector
in interface NioSelector
protected final void increaseCancelledKeys()
protected final boolean cleanUpCancelledKeys() throws IOException
IOException
public void shutdown()
shutdown
in interface NioSelector
protected int select(Selector selector) throws IOException
IOException
Copyright © 2008-2014 The Netty Project. All Rights Reserved.