Package 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
,ThreadAwareExecutor
,java.lang.Iterable<EventExecutor>
,java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
,java.util.concurrent.ScheduledExecutorService
public final class DefaultEventExecutor extends SingleThreadEventExecutor
DefaultSingleThreadEventExecutor
implementation which just execute all submitted task in a serial fashion.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class io.netty.util.concurrent.SingleThreadEventExecutor
SingleThreadEventExecutor.NonWakeupRunnable
-
Nested classes/interfaces inherited from class io.netty.util.concurrent.AbstractEventExecutor
AbstractEventExecutor.LazyRunnable
-
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
run()
Run the tasks in theSingleThreadEventExecutor.taskQueue
-
Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor
addShutdownHook, addTask, afterRunningAllTasks, awaitTermination, canSuspend, canSuspend, cleanup, confirmShutdown, deadlineNanos, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isSuspended, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, peekTask, pendingTasks, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, trySuspend, updateLastExecutionTime, wakesUpForTask, wakeup
-
Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor
afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, delayNanos, fetchFromScheduledTaskQueue, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled
-
Methods inherited from class io.netty.util.concurrent.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 io.netty.util.concurrent.EventExecutor
inEventLoop, isExecutorThread, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent
-
Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup
iterator, next, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
-
-
-
-
Constructor Detail
-
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 Detail
-
run
protected void run()
Description copied from class:SingleThreadEventExecutor
Run the tasks in theSingleThreadEventExecutor.taskQueue
- Specified by:
run
in classSingleThreadEventExecutor
-
-