public class DefaultEventLoop extends SingleThreadEventLoop
SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>
SingleThreadEventExecutor.NonWakeupRunnable
AbstractEventExecutor.LazyRunnable
DEFAULT_MAX_PENDING_TASKS
Constructor and Description |
---|
DefaultEventLoop() |
DefaultEventLoop(EventLoopGroup parent) |
DefaultEventLoop(EventLoopGroup parent,
Executor executor) |
DefaultEventLoop(EventLoopGroup parent,
ThreadFactory threadFactory) |
DefaultEventLoop(Executor executor) |
DefaultEventLoop(ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
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
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated
forEach, spliterator
public DefaultEventLoop()
public DefaultEventLoop(ThreadFactory threadFactory)
public DefaultEventLoop(Executor executor)
public DefaultEventLoop(EventLoopGroup parent)
public DefaultEventLoop(EventLoopGroup parent, ThreadFactory threadFactory)
public DefaultEventLoop(EventLoopGroup parent, Executor executor)
protected void run()
SingleThreadEventExecutor
SingleThreadEventExecutor.taskQueue
run
in class SingleThreadEventExecutor
Copyright © 2008–2024 The Netty Project. All rights reserved.