final class DefaultEventExecutor extends SingleThreadEventExecutor
SingleThreadEventExecutor implementation which just execute all submitted task in a
serial fashionDEFAULT_MAX_PENDING_EXECUTOR_TASKSscheduledTaskQueue| 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, wakeupcancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, peekScheduledTask, pollScheduledTask, pollScheduledTask, removeScheduled, schedule, schedule, schedule, scheduleAtFixedRate, scheduledTaskQueue, scheduleWithFixedDelayinEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, next, shutdownGracefully, shutdownNow, submit, submit, submitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, nextiterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitDefaultEventExecutor(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