org.jboss.netty.channel.socket.nio

类 NioServerBoss

java.lang.Object

org.jboss.netty.channel.socket.nio.NioServerBoss

所有已实现的接口:

java.lang.Runnable, Boss, NioSelector

public final class NioServerBoss
extends java.lang.Object
implements Boss

Boss implementation which handles accepting of new connections

字段概要

字段

限定符和类型	字段和说明
protected static InternalLogger	logger Internal Netty logger.
protected java.nio.channels.Selector	selector The NIO Selector.
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.

方法概要

方法

限定符和类型	方法和说明
protected boolean	cleanUpCancelledKeys()
protected void	close(java.nio.channels.SelectionKey k)
protected java.lang.Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected void	increaseCancelledKeys()
protected boolean	isIoThread()
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(java.nio.channels.Selector selector)
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 int	select(java.nio.channels.Selector selector)
void	shutdown()

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

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

从接口继承的方法 org.jboss.netty.channel.socket.nio.NioSelector

rebuildSelector, register, shutdown

从接口继承的方法 java.lang.Runnable

run

字段详细资料

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.

方法详细资料

close

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

process

protected void process(java.nio.channels.Selector selector)

select

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

抛出:

java.io.IOException

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
                                               ThreadNameDeterminer determiner)

createRegisterTask

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

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

run

public void run()

指定者:

run 在接口中 java.lang.Runnable

increaseCancelledKeys

protected final void increaseCancelledKeys()

cleanUpCancelledKeys

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

抛出:

java.io.IOException

shutdown

public void shutdown()

指定者:

shutdown 在接口中 NioSelector