io.netty.channel.epoll

类 EpollEventLoop

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.epoll.EpollEventLoop

所有已实现的接口:

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

public class EpollEventLoop
extends SingleThreadEventLoop

EventLoop which uses epoll under the covers. Only works on Linux!

嵌套类概要

从类继承的嵌套类/接口 io.netty.channel.SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>

从类继承的嵌套类/接口 io.netty.util.concurrent.SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

从类继承的嵌套类/接口 io.netty.util.concurrent.AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

字段概要

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

DEFAULT_MAX_PENDING_TASKS

方法概要

限定符和类型	方法和说明
protected boolean	afterScheduledTaskSubmitted(long deadlineNanos) See AbstractScheduledEventExecutor.beforeScheduledTaskSubmitted(long).
protected boolean	beforeScheduledTaskSubmitted(long deadlineNanos) Called from arbitrary non-EventExecutor threads prior to scheduled task submission.
protected void	cleanup() Do nothing, sub-classes may override
void	closeFileDescriptors() This method is intended for use by process checkpoint/restore integration, such as OpenJDK CRaC.
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.
void	openFileDescriptors() This method is intended for use by a process checkpoint/restore integration, such as OpenJDK CRaC.
int	registeredChannels() Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
java.util.Iterator<Channel>	registeredChannelsIterator()
protected void	run() Run the tasks in the SingleThreadEventExecutor.taskQueue
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

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

从类继承的方法 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

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

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

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

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

从接口继承的方法 java.lang.Iterable

forEach, spliterator

方法详细资料

openFileDescriptors

@UnstableApi
public void openFileDescriptors()

This method is intended for use by a process checkpoint/restore integration, such as OpenJDK CRaC.

wakeup

protected void wakeup(boolean inEventLoop)

覆盖:

wakeup 在类中 SingleThreadEventExecutor

beforeScheduledTaskSubmitted

protected boolean beforeScheduledTaskSubmitted(long deadlineNanos)

从类复制的说明: AbstractScheduledEventExecutor

Called from arbitrary non-EventExecutor threads prior to scheduled task submission. Returns true if the EventExecutor thread should be woken immediately to process the scheduled task (if not already awake).

If false is returned, AbstractScheduledEventExecutor.afterScheduledTaskSubmitted(long) will be called with the same value after the scheduled task is enqueued, providing another opportunity to wake the EventExecutor thread if required.

覆盖:

beforeScheduledTaskSubmitted 在类中 AbstractScheduledEventExecutor

参数:

deadlineNanos - deadline of the to-be-scheduled task relative to AbstractScheduledEventExecutor.getCurrentTimeNanos()

返回:

true if the EventExecutor thread should be woken, false otherwise

afterScheduledTaskSubmitted

protected boolean afterScheduledTaskSubmitted(long deadlineNanos)

从类复制的说明: AbstractScheduledEventExecutor

See AbstractScheduledEventExecutor.beforeScheduledTaskSubmitted(long). Called only after that method returns false.

覆盖:

afterScheduledTaskSubmitted 在类中 AbstractScheduledEventExecutor

参数:

deadlineNanos - relative to AbstractScheduledEventExecutor.getCurrentTimeNanos()

返回:

true if the EventExecutor thread should be woken, false otherwise

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

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.

registeredChannels

public int registeredChannels()

从类复制的说明: 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.

覆盖:

registeredChannels 在类中 SingleThreadEventLoop

registeredChannelsIterator

public java.util.Iterator<Channel> registeredChannelsIterator()

覆盖:

registeredChannelsIterator 在类中 SingleThreadEventLoop

返回:

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

从类复制的说明: SingleThreadEventExecutor

Run the tasks in the SingleThreadEventExecutor.taskQueue

指定者:

run 在类中 SingleThreadEventExecutor

cleanup

protected void cleanup()

从类复制的说明: SingleThreadEventExecutor

Do nothing, sub-classes may override

覆盖:

cleanup 在类中 SingleThreadEventExecutor

closeFileDescriptors

@UnstableApi
public void closeFileDescriptors()

This method is intended for use by process checkpoint/restore integration, such as OpenJDK CRaC. It's up to the caller to ensure that there is no concurrent use of the FDs while these are closed, e.g. by blocking the executor.