Class NioWorker
java.lang.Object
org.jboss.netty.channel.socket.nio.AbstractNioSelector
org.jboss.netty.channel.socket.nio.AbstractNioWorker
org.jboss.netty.channel.socket.nio.NioWorker
- All Implemented Interfaces:
Runnable
,NioSelector
,Worker
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsFields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioWorker
sendBufferPool
Fields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector
logger, selector, startupLatch, thread, wakenUp
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Runnable
createRegisterTask
(Channel channel, ChannelFuture future) protected boolean
read
(SelectionKey k) Read is called when a Selector has been notified that the underlying channel was something to be read.void
run()
protected boolean
scheduleWriteIfNecessary
(AbstractNioChannel<?> channel) Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioWorker
cleanUpWriteBuffer, clearOpWrite, close, close, executeInIoThread, executeInIoThread, isIoThread, newThreadRenamingRunnable, process, setInterestOps, setOpWrite, write0, writeFromSelectorLoop, writeFromTaskLoop, writeFromUserCode
Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector
cleanUpCancelledKeys, increaseCancelledKeys, isIoThread, rebuildSelector, register, registerTask, select, shutdown
-
Field Details
-
recvBufferPool
-
-
Constructor Details
-
NioWorker
-
NioWorker
-
-
Method Details
-
read
Description copied from class:AbstractNioWorker
Read is called when a Selector has been notified that the underlying channel was something to be read. The channel would previously have registered its interest in read operations.- Specified by:
read
in classAbstractNioWorker
- Parameters:
k
- The selection key which contains the Selector registration information.
-
scheduleWriteIfNecessary
- Specified by:
scheduleWriteIfNecessary
in classAbstractNioWorker
-
createRegisterTask
- Specified by:
createRegisterTask
in classAbstractNioSelector
-
run
public void run()- Specified by:
run
in interfaceRunnable
- Overrides:
run
in classAbstractNioWorker
-