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, io.netty.util.concurrent.EventExecutor, io.netty.util.concurrent.EventExecutorGroup, io.netty.util.concurrent.OrderedEventExecutor, Iterable<io.netty.util.concurrent.EventExecutor>, Executor, ExecutorService, 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.

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.channel.SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>

Nested classes/interfaces inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

io.netty.util.concurrent.SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractEventExecutor.LazyRunnable

Field Summary

Fields inherited from class io.netty.channel.SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Method Summary

Modifier and Type	Method and Description
protected boolean	afterScheduledTaskSubmitted(long deadlineNanos)
protected boolean	beforeScheduledTaskSubmitted(long deadlineNanos)
protected void	cleanup()
int	getIoRatio() Returns the percentage of the desired amount of time spent for I/O in the event loop.
protected Queue<Runnable>	newTaskQueue(int maxPendingTasks)
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.
int	registeredChannels() Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
Iterator<Channel>	registeredChannelsIterator()
protected void	run()
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)

Methods inherited from class io.netty.channel.SingleThreadEventLoop

afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, register, register

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

addShutdownHook, addTask, awaitTermination, confirmShutdown, deadlineNanos, delayNanos, execute, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, lazyExecute, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask

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

cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled

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

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

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

inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

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

isShuttingDown, iterator, 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.Iterable

forEach, spliterator

Method Detail

selectorProvider

public SelectorProvider selectorProvider()

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

newTaskQueue

protected Queue<Runnable> newTaskQueue(int maxPendingTasks)

Overrides:

newTaskQueue in class io.netty.util.concurrent.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. Value range from 1-100. 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. The lower the number the more time can be spent on non-I/O tasks. If value set to 100, this feature will be disabled and event loop will not attempt to balance I/O and 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.

registeredChannels

public int registeredChannels()

Description copied from class: SingleThreadEventLoop

Returns the number of Channels registered with this EventLoop or -1 if operation is not supported. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort.

Overrides:

registeredChannels in class SingleThreadEventLoop

registeredChannelsIterator

public Iterator<Channel> registeredChannelsIterator()

Overrides:

registeredChannelsIterator in class SingleThreadEventLoop

Returns:

read-only iterator of active Channels registered with this EventLoop. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort. This method is expected to be called from within event loop.

run

protected void run()

Specified by:

run in class io.netty.util.concurrent.SingleThreadEventExecutor

cleanup

protected void cleanup()

Overrides:

cleanup in class io.netty.util.concurrent.SingleThreadEventExecutor

wakeup

protected void wakeup(boolean inEventLoop)

Overrides:

wakeup in class io.netty.util.concurrent.SingleThreadEventExecutor

beforeScheduledTaskSubmitted

protected boolean beforeScheduledTaskSubmitted(long deadlineNanos)

Overrides:

beforeScheduledTaskSubmitted in class io.netty.util.concurrent.AbstractScheduledEventExecutor

afterScheduledTaskSubmitted

protected boolean afterScheduledTaskSubmitted(long deadlineNanos)

Overrides:

afterScheduledTaskSubmitted in class io.netty.util.concurrent.AbstractScheduledEventExecutor