org.jboss.netty.channel.socket.nio

类 NioWorker

java.lang.Object

org.jboss.netty.channel.socket.nio.NioWorker

所有已实现的接口:

java.lang.Runnable, NioSelector, Worker

public class NioWorker
extends java.lang.Object

字段概要

字段

限定符和类型	字段和说明
protected static InternalLogger	logger Internal Netty logger.
protected java.nio.channels.Selector	selector The NIO Selector.
protected org.jboss.netty.channel.socket.nio.SocketSendBufferPool	sendBufferPool
protected java.lang.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 java.util.concurrent.atomic.AtomicBoolean	wakenUp Boolean that controls determines if a blocked Selector.select should break out of its selection process.

构造器概要

构造器

构造器和说明
NioWorker(java.util.concurrent.Executor executor)
NioWorker(java.util.concurrent.Executor executor, ThreadNameDeterminer determiner)

方法概要

方法

限定符和类型	方法和说明
protected boolean	cleanUpCancelledKeys()
protected static void	cleanUpWriteBuffer(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)
protected void	clearOpWrite(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)
protected void	close(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel, ChannelFuture future)
protected void	close(java.nio.channels.SelectionKey k)
protected java.lang.Runnable	createRegisterTask(Channel channel, ChannelFuture future)
void	executeInIoThread(java.lang.Runnable task) Execute the given Runnable in the IO-Thread.
void	executeInIoThread(java.lang.Runnable task, boolean alwaysAsync) Execute the Runnable in a IO-Thread
protected void	increaseCancelledKeys()
protected boolean	isIoThread()
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(java.nio.channels.Selector selector)
protected boolean	read(java.nio.channels.SelectionKey k) Read is called when a Selector has been notified that the underlying channel was something to be read.
void	rebuildSelector() Replaces the current Selector with a new Selector to work around the infamous epoll 100% CPU bug.
void	register(Channel channel, ChannelFuture future)
protected void	registerTask(java.lang.Runnable task)
void	run()
protected boolean	scheduleWriteIfNecessary(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)
protected int	select(java.nio.channels.Selector selector)
protected void	setOpWrite(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)
void	shutdown()
protected void	write0(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

sendBufferPool

protected final org.jboss.netty.channel.socket.nio.SocketSendBufferPool sendBufferPool

logger

protected static final InternalLogger logger

Internal Netty logger.

thread

protected volatile java.lang.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.

selector

protected volatile java.nio.channels.Selector selector

The NIO Selector.

wakenUp

protected final java.util.concurrent.atomic.AtomicBoolean wakenUp

Boolean that controls determines if a blocked Selector.select should break out of its selection process. In our case we use a timeone for the select method and the select method will block for that time unless waken up.

构造器详细资料

NioWorker

public NioWorker(java.util.concurrent.Executor executor)

NioWorker

public NioWorker(java.util.concurrent.Executor executor,
         ThreadNameDeterminer determiner)

方法详细资料

read

protected boolean read(java.nio.channels.SelectionKey k)

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.

参数:

k - The selection key which contains the Selector registration information.

scheduleWriteIfNecessary

protected boolean scheduleWriteIfNecessary(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

createRegisterTask

protected java.lang.Runnable createRegisterTask(Channel channel,
                                    ChannelFuture future)

run

public void run()

指定者:

run 在接口中 java.lang.Runnable

executeInIoThread

public void executeInIoThread(java.lang.Runnable task)

从接口复制的说明: Worker

Execute the given Runnable in the IO-Thread. This may be now or later once the IO-Thread do some other work.

指定者:

executeInIoThread 在接口中 Worker

参数:

task - the Runnable to execute

executeInIoThread

public void executeInIoThread(java.lang.Runnable task,
                     boolean alwaysAsync)

Execute the Runnable in a IO-Thread

参数:

task - the Runnable to execute

alwaysAsync - true if the Runnable should be executed in an async fashion even if the current Thread == IO Thread

close

protected void close(java.nio.channels.SelectionKey k)

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
                                               ThreadNameDeterminer determiner)

process

protected void process(java.nio.channels.Selector selector)
                throws java.io.IOException

抛出:

java.io.IOException

write0

protected void write0(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

setOpWrite

protected void setOpWrite(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

clearOpWrite

protected void clearOpWrite(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

close

protected void close(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel,
         ChannelFuture future)

cleanUpWriteBuffer

protected static void cleanUpWriteBuffer(org.jboss.netty.channel.socket.nio.AbstractNioChannel<?> channel)

register

public void register(Channel channel,
            ChannelFuture future)

指定者:

register 在接口中 NioSelector

registerTask

protected final void registerTask(java.lang.Runnable task)

isIoThread

protected final boolean isIoThread()

rebuildSelector

public void rebuildSelector()

从接口复制的说明: NioSelector

Replaces the current Selector with a new Selector to work around the infamous epoll 100% CPU bug.

指定者:

rebuildSelector 在接口中 NioSelector

increaseCancelledKeys

protected final void increaseCancelledKeys()

cleanUpCancelledKeys

protected final boolean cleanUpCancelledKeys()
                                      throws java.io.IOException

抛出:

java.io.IOException

shutdown

public void shutdown()

指定者:

shutdown 在接口中 NioSelector

select

protected int select(java.nio.channels.Selector selector)
              throws java.io.IOException

抛出:

java.io.IOException