io.netty.channel.nio

类 NioEventLoop

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractScheduledEventExecutor

io.netty.util.concurrent.SingleThreadEventExecutor

io.netty.channel.SingleThreadEventLoop

io.netty.channel.nio.NioEventLoop

所有已实现的接口:

EventLoop, EventLoopGroup, EventExecutor, EventExecutorGroup, OrderedEventExecutor, java.lang.Iterable<EventExecutor>, java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

public final class NioEventLoop
extends SingleThreadEventLoop

SingleThreadEventLoop implementation which register the Channel's to a Selector and so does the multi-plexing of these in the event loop.

字段概要

从类继承的字段 io.netty.channel.SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

方法概要

方法

限定符和类型	方法和说明
protected void	cleanup() Do nothing, sub-classes may override
int	getIoRatio() Returns the percentage of the desired amount of time spent for I/O in the event loop.
protected java.util.Queue<java.lang.Runnable>	newTaskQueue(int maxPendingTasks) Create a new Queue which will holds the tasks to execute.
int	pendingTasks() Return the number of tasks that are pending for processing.
protected java.lang.Runnable	pollTask()
void	rebuildSelector() Replaces the current Selector of this event loop with newly created Selectors to work around the infamous epoll 100% CPU bug.
void	register(java.nio.channels.SelectableChannel ch, int interestOps, NioTask<?> task) Registers an arbitrary SelectableChannel, not necessarily created by Netty, to the Selector of this event loop.
protected void	run()
java.nio.channels.spi.SelectorProvider	selectorProvider() Returns the SelectorProvider used by this NioEventLoop to obtain the Selector.
void	setIoRatio(int ioRatio) Sets the percentage of the desired amount of time spent for I/O in the event loop.
protected void	wakeup(boolean inEventLoop)

从类继承的方法 io.netty.channel.SingleThreadEventLoop

next, parent, register, register, wakesUpForTask

从类继承的方法 io.netty.util.concurrent.SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, newTaskQueue, peekTask, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime

从类继承的方法 io.netty.util.concurrent.AbstractScheduledEventExecutor

cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

从类继承的方法 io.netty.util.concurrent.AbstractEventExecutor

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, shutdownGracefully, shutdownNow, submit, submit, submit

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

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

从接口继承的方法 io.netty.util.concurrent.EventExecutor

inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

从接口继承的方法 io.netty.util.concurrent.EventExecutorGroup

isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture

从接口继承的方法 java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

从接口继承的方法 java.util.concurrent.Executor

execute

方法详细资料

selectorProvider

public java.nio.channels.spi.SelectorProvider selectorProvider()

Returns the SelectorProvider used by this NioEventLoop to obtain the Selector.

newTaskQueue

protected java.util.Queue<java.lang.Runnable> newTaskQueue(int maxPendingTasks)

从类复制的说明: SingleThreadEventExecutor

Create a new Queue which will holds the tasks to execute. This default implementation will return a LinkedBlockingQueue but if your sub-class of SingleThreadEventExecutor will not do any blocking calls on the this Queue it may make sense to @Override this and return some more performant implementation that does not support blocking operations at all.

覆盖:

newTaskQueue 在类中 SingleThreadEventExecutor

pendingTasks

public int pendingTasks()

从类复制的说明: SingleThreadEventExecutor

Return the number of tasks that are pending for processing. Be aware that this operation may be expensive as it depends on the internal implementation of the SingleThreadEventExecutor. So use it was care!

覆盖:

pendingTasks 在类中 SingleThreadEventExecutor

register

public void register(java.nio.channels.SelectableChannel ch,
            int interestOps,
            NioTask<?> task)

Registers an arbitrary SelectableChannel, not necessarily created by Netty, to the Selector of this event loop. Once the specified SelectableChannel is registered, the specified task will be executed by this event loop when the SelectableChannel is ready.

getIoRatio

public int getIoRatio()

Returns the percentage of the desired amount of time spent for I/O in the event loop.

setIoRatio

public void setIoRatio(int ioRatio)

Sets the percentage of the desired amount of time spent for I/O in the event loop. The default value is 50, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks.

rebuildSelector

public void rebuildSelector()

Replaces the current Selector of this event loop with newly created Selectors to work around the infamous epoll 100% CPU bug.

run

protected void run()

指定者:

run 在类中 SingleThreadEventExecutor

cleanup

protected void cleanup()

从类复制的说明: SingleThreadEventExecutor

Do nothing, sub-classes may override

覆盖:

cleanup 在类中 SingleThreadEventExecutor

pollTask

protected java.lang.Runnable pollTask()

覆盖:

pollTask 在类中 SingleThreadEventExecutor

另请参阅:

Queue.poll()

wakeup

protected void wakeup(boolean inEventLoop)

覆盖:

wakeup 在类中 SingleThreadEventExecutor