All Implemented Interfaces:

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 

• Field Summary

  • Fields inherited from class io.netty.channel.SingleThreadEventLoop

    DEFAULT_MAX_PENDING_TASKS

• Method Summary

  All 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 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)

  • Methods inherited from class io.netty.channel.SingleThreadEventLoop

    next, parent, register, register, wakesUpForTask

  • Methods inherited from class 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

  • 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

    inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, 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 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)

    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

  • pendingTasks

    public int pendingTasks()

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

    Overrides:

    pendingTasks in class 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()

    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 java.lang.Runnable pollTask()

    Overrides:

    pollTask in class SingleThreadEventExecutor

    See Also:

    Queue.poll()

  • wakeup

    protected void wakeup(boolean inEventLoop)

    Overrides:

    wakeup in class SingleThreadEventExecutor