Class DefaultEventExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractScheduledEventExecutor

io.netty.util.concurrent.SingleThreadEventExecutor

io.netty.util.concurrent.DefaultEventExecutor

All Implemented Interfaces:

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

public final class DefaultEventExecutor
extends SingleThreadEventExecutor

Default SingleThreadEventExecutor implementation which just execute all submitted task in a serial fashion.

Nested Class Summary

Nested classes/interfaces inherited from class SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

Field Summary

Fields inherited from class SingleThreadEventExecutor

DEFAULT_MAX_PENDING_EXECUTOR_TASKS

Fields inherited from class AbstractScheduledEventExecutor

nextTaskId, scheduledTaskQueue, WAKEUP_TASK

Fields inherited from class AbstractEventExecutor

DEFAULT_SHUTDOWN_QUIET_PERIOD, DEFAULT_SHUTDOWN_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
DefaultEventExecutor()
DefaultEventExecutor(EventExecutorGroup parent)
DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor)
DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory)
DefaultEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutor(java.util.concurrent.Executor executor)
DefaultEventExecutor(java.util.concurrent.ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
protected void	run()	Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Methods inherited from class SingleThreadEventExecutor

addShutdownHook, addTask, afterRunningAllTasks, awaitTermination, canSuspend, canSuspend, cleanup, confirmShutdown, deadlineNanos, delayNanos, drainTasks, execute, getAndIncrementBusyCycles, getAndIncrementIdleCycles, getAndResetAccumulatedActiveTimeNanos, getLastActivityTimeNanos, getNumOfRegisteredChannels, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isSuspended, isSuspensionSupported, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, offerTask, peekTask, pendingTasks, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, reportActiveIoTime, resetBusyCycles, resetIdleCycles, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, scheduleRemoveScheduled, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, trySuspend, updateLastExecutionTime, wakesUpForTask, wakeup

Methods inherited from class AbstractScheduledEventExecutor

afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineNanos, deadlineToDelayNanos, defaultCurrentTimeNanos, delayNanos, fetchFromScheduledTaskQueue, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, peekScheduledTask, pollScheduledTask, pollScheduledTask, removeScheduled, schedule, schedule, scheduleAtFixedRate, scheduledTaskQueue, scheduleFromEventLoop, scheduleWithFixedDelay, ticker, validateScheduled

Methods inherited from class AbstractEventExecutor

iterator, newTaskFor, newTaskFor, next, parent, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface EventExecutor

inEventLoop, isExecutorThread, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent

Methods inherited from interface EventExecutorGroup

iterator, next, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit, ticker

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

DefaultEventExecutor

public DefaultEventExecutor()

DefaultEventExecutor

public DefaultEventExecutor(java.util.concurrent.ThreadFactory threadFactory)

DefaultEventExecutor

public DefaultEventExecutor(java.util.concurrent.Executor executor)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
 java.util.concurrent.ThreadFactory threadFactory)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
 java.util.concurrent.Executor executor)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
 java.util.concurrent.ThreadFactory threadFactory,
 int maxPendingTasks,
 RejectedExecutionHandler rejectedExecutionHandler)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
 java.util.concurrent.Executor executor,
 int maxPendingTasks,
 RejectedExecutionHandler rejectedExecutionHandler)

Method Details

run

protected void run()

Description copied from class: SingleThreadEventExecutor

Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Implementations must not let a Throwable thrown by a task escape this method: any uncaught Throwable terminates the executor (logged at WARN and surfaced via SingleThreadEventExecutor.terminationFuture()), at which point every Channel registered with this executor stops processing I/O and new task submissions are rejected. The supplied helpers - SingleThreadEventExecutor.runAllTasks(), SingleThreadEventExecutor.runAllTasks(long), and AbstractEventExecutor.safeExecute(Runnable) - catch Throwable for you; custom loops built on SingleThreadEventExecutor.pollTask() or SingleThreadEventExecutor.takeTask() are responsible for wrapping each task invocation accordingly.

Specified by:

run in class SingleThreadEventExecutor