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.SingleThreadIoEventLoop

io.netty.channel.nio.NioEventLoop

All Implemented Interfaces:

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

@Deprecated
public final class NioEventLoop
extends SingleThreadIoEventLoop

Deprecated.

Use SingleThreadIoEventLoop with NioIoHandler

SingleThreadIoEventLoop 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 SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T>

Nested classes/interfaces inherited from class SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private static final InternalLogger	logger	Deprecated.

Fields inherited from class SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Constructors

Constructor	Description
NioEventLoop(NioEventLoopGroup parent, java.util.concurrent.Executor executor, IoHandlerFactory ioHandlerFactory, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory, RejectedExecutionHandler rejectedExecutionHandler)	Deprecated.

Method Summary

Modifier and Type	Method	Description
private static java.util.Queue<java.lang.Runnable>	newTaskQueue(EventLoopTaskQueueFactory queueFactory)	Deprecated.
void	rebuildSelector()	Deprecated. 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)	Deprecated. Registers an arbitrary SelectableChannel, not necessarily created by Netty, to the Selector of this event loop.
private void	register0(java.nio.channels.SelectableChannel ch, int interestOps, NioTask<java.nio.channels.SelectableChannel> task)	Deprecated.
int	registeredChannels()	Deprecated. Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
java.util.Iterator<Channel>	registeredChannelsIterator()	Deprecated.
java.nio.channels.spi.SelectorProvider	selectorProvider()	Deprecated. Returns the SelectorProvider used by this NioEventLoop to obtain the Selector.
(package private) java.nio.channels.Selector	unwrappedSelector()	Deprecated.

Methods inherited from class SingleThreadIoEventLoop

canSuspend, cleanup, getIoRatio, getNumOfRegisteredChannels, ioHandler, isCompatible, isIoType, newTaskQueue, newTaskQueue0, next, register, run, runIo, setIoRatio, wakeup

Methods inherited from class SingleThreadEventLoop

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

Methods inherited from class SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, canSuspend, confirmShutdown, deadlineNanos, delayNanos, execute, getAndIncrementBusyCycles, getAndIncrementIdleCycles, getAndResetAccumulatedActiveTimeNanos, getLastActivityTimeNanos, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isSuspended, isSuspensionSupported, isTerminated, lazyExecute, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, reportActiveIoTime, resetBusyCycles, resetIdleCycles, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, trySuspend, updateLastExecutionTime, wakesUpForTask

Methods inherited from class AbstractScheduledEventExecutor

afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, delayNanos, fetchFromScheduledTaskQueue, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, ticker, validateScheduled

Methods inherited from class AbstractEventExecutor

iterator, 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 EventExecutor

inEventLoop, inEventLoop, isExecutorThread, isSuspended, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, trySuspend

Methods inherited from interface EventExecutorGroup

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

Methods inherited from interface EventLoop

parent

Methods inherited from interface EventLoopGroup

register

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

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

Methods inherited from interface IoEventLoopGroup

register, register

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

logger

private static final InternalLogger logger

Deprecated.

Constructor Details

NioEventLoop

NioEventLoop(NioEventLoopGroup parent,
 java.util.concurrent.Executor executor,
 IoHandlerFactory ioHandlerFactory,
 EventLoopTaskQueueFactory taskQueueFactory,
 EventLoopTaskQueueFactory tailTaskQueueFactory,
 RejectedExecutionHandler rejectedExecutionHandler)

Deprecated.

Method Details

newTaskQueue

private static java.util.Queue<java.lang.Runnable> newTaskQueue(EventLoopTaskQueueFactory queueFactory)

Deprecated.

selectorProvider

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

Deprecated.

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

register

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

Deprecated.

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.

register0

private void register0(java.nio.channels.SelectableChannel ch,
 int interestOps,
 NioTask<java.nio.channels.SelectableChannel> task)

Deprecated.

rebuildSelector

public void rebuildSelector()

Deprecated.

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

Deprecated.

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 java.util.Iterator<Channel> registeredChannelsIterator()

Deprecated.

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.

unwrappedSelector

java.nio.channels.Selector unwrappedSelector()

Deprecated.