io.netty.channel.nio

Class 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

All Implemented Interfaces:

EventLoop, EventLoopGroup, EventExecutor, EventExecutorGroup, AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

public final class NioEventLoop
extends SingleThreadEventLoop

A SingleThreadEventLoop implementation which registers each Channel with a NIO Selector and performs the multiplexing of these in the event loop.

Method Summary

Methods

Modifier and Type	Method and Description
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 Queue<Runnable>	newTaskQueue() Create a new Queue which will holds the tasks to execute.
protected 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(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()
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)

Methods inherited from class io.netty.channel.SingleThreadEventLoop

asInvoker, next, parent, register, register, unwrap, wakesUpForTask

Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, cleanupAndTerminate, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, isShutdown, isShuttingDown, isTerminated, peekTask, pendingTasks, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, scheduleExecution, shutdown, shutdownGracefully, takeTask, terminationFuture, updateLastExecutionTime

Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor

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

Methods inherited from class io.netty.util.concurrent.AbstractEventExecutor

children, close, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.util.concurrent.EventExecutor

children, inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup

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

Methods inherited from interface java.util.concurrent.ExecutorService

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

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

newTaskQueue

protected Queue<Runnable> newTaskQueue()

Description copied from class: 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.

Overrides:

newTaskQueue in class SingleThreadEventExecutor

register

public void register(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()

Specified by:

run in class SingleThreadEventExecutor

cleanup

protected void cleanup()

Description copied from class: SingleThreadEventExecutor

Do nothing, sub-classes may override

Overrides:

cleanup in class SingleThreadEventExecutor

pollTask

protected Runnable pollTask()

Overrides:

pollTask in class SingleThreadEventExecutor

See Also:

Queue#poll()}

wakeup

protected void wakeup(boolean inEventLoop)

Overrides:

wakeup in class SingleThreadEventExecutor