final class DefaultEventExecutor extends SingleThreadEventExecutor
SingleThreadEventExecutor
implementation which just execute all submitted task in a
serial fashionDEFAULT_MAX_PENDING_EXECUTOR_TASKS
scheduledTaskQueue
Constructor and Description |
---|
DefaultEventExecutor(DefaultEventExecutorGroup parent,
java.util.concurrent.ThreadFactory threadFactory) |
DefaultEventExecutor(DefaultEventExecutorGroup parent,
java.util.concurrent.ThreadFactory threadFactory,
int maxPendingTasks,
RejectedExecutionHandler rejectedExecutionHandler) |
Modifier and Type | Method and Description |
---|---|
protected void |
run() |
addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, newTaskQueue, newTaskQueue, offerTask, parent, peekTask, pendingTasks, pollTask, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask, wakeup
cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, peekScheduledTask, pollScheduledTask, pollScheduledTask, removeScheduled, schedule, schedule, schedule, scheduleAtFixedRate, scheduledTaskQueue, scheduleWithFixedDelay
inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, next, shutdownGracefully, shutdownNow, submit, submit, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, next
iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
DefaultEventExecutor(DefaultEventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory)
DefaultEventExecutor(DefaultEventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
protected void run()
run
in class SingleThreadEventExecutor