public class DefaultEventLoop extends SingleThreadEventLoop
SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>
SingleThreadEventExecutor.NonWakeupRunnable
AbstractEventExecutor.LazyRunnable
DEFAULT_MAX_PENDING_TASKS
构造器和说明 |
---|
DefaultEventLoop() |
DefaultEventLoop(EventLoopGroup parent) |
DefaultEventLoop(EventLoopGroup parent,
java.util.concurrent.Executor executor) |
DefaultEventLoop(EventLoopGroup parent,
java.util.concurrent.ThreadFactory threadFactory) |
DefaultEventLoop(java.util.concurrent.Executor executor) |
DefaultEventLoop(java.util.concurrent.ThreadFactory threadFactory) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
run()
Run the tasks in the
SingleThreadEventExecutor.taskQueue |
afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, register, register, registeredChannels, registeredChannelsIterator
addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, deadlineNanos, delayNanos, execute, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask, wakeup
afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled
inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture
isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture
public DefaultEventLoop()
public DefaultEventLoop(java.util.concurrent.ThreadFactory threadFactory)
public DefaultEventLoop(java.util.concurrent.Executor executor)
public DefaultEventLoop(EventLoopGroup parent)
public DefaultEventLoop(EventLoopGroup parent, java.util.concurrent.ThreadFactory threadFactory)
public DefaultEventLoop(EventLoopGroup parent, java.util.concurrent.Executor executor)
protected void run()
SingleThreadEventExecutor
SingleThreadEventExecutor.taskQueue
run
在类中 SingleThreadEventExecutor