io.netty.util.concurrent

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, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

public final class DefaultEventExecutor
extends SingleThreadEventExecutor

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

Constructor Summary

Constructors

Constructor and Description
DefaultEventExecutor()
DefaultEventExecutor(EventExecutorGroup parent)
DefaultEventExecutor(EventExecutorGroup parent, Executor executor)
DefaultEventExecutor(EventExecutorGroup parent, Executor executor, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutor(EventExecutorGroup parent, ThreadFactory threadFactory)
DefaultEventExecutor(EventExecutorGroup parent, ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedExecutionHandler)
DefaultEventExecutor(Executor executor)
DefaultEventExecutor(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
protected void	run()

Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

addShutdownHook, addTask, afterRunningAllTasks, awaitTermination, cleanup, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, newTaskQueue, newTaskQueue, peekTask, pendingTasks, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask, wakeup

Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor

cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from class io.netty.util.concurrent.AbstractEventExecutor

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, next, parent, 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 io.netty.util.concurrent.EventExecutor

inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, next, parent

Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultEventExecutor

public DefaultEventExecutor()

DefaultEventExecutor

public DefaultEventExecutor(ThreadFactory threadFactory)

DefaultEventExecutor

public DefaultEventExecutor(Executor executor)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
                            ThreadFactory threadFactory)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
                            Executor executor)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
                            ThreadFactory threadFactory,
                            int maxPendingTasks,
                            RejectedExecutionHandler rejectedExecutionHandler)

DefaultEventExecutor

public DefaultEventExecutor(EventExecutorGroup parent,
                            Executor executor,
                            int maxPendingTasks,
                            RejectedExecutionHandler rejectedExecutionHandler)

Method Detail

run

protected void run()

Specified by:

run in class SingleThreadEventExecutor