Package io.netty.util.concurrent
Class SingleThreadEventExecutor
- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- io.netty.util.concurrent.AbstractEventExecutor
-
- io.netty.util.concurrent.AbstractScheduledEventExecutor
-
- io.netty.util.concurrent.SingleThreadEventExecutor
-
- All Implemented Interfaces:
EventExecutor,EventExecutorGroup,OrderedEventExecutor,java.lang.Iterable<EventExecutor>,java.util.concurrent.Executor,java.util.concurrent.ExecutorService,java.util.concurrent.ScheduledExecutorService
- Direct Known Subclasses:
DefaultEventExecutor,SingleThreadEventLoop
public abstract class SingleThreadEventExecutor extends AbstractScheduledEventExecutor implements OrderedEventExecutor
Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static classSingleThreadEventExecutor.DefaultThreadPropertiesprotected static interfaceSingleThreadEventExecutor.NonWakeupRunnableDeprecated.-
Nested classes/interfaces inherited from class io.netty.util.concurrent.AbstractEventExecutor
AbstractEventExecutor.LazyRunnable
-
-
Field Summary
Fields Modifier and Type Field Description private booleanaddTaskWakesUp(package private) static intDEFAULT_MAX_PENDING_EXECUTOR_TASKSprivate java.util.concurrent.Executorexecutorprivate longgracefulShutdownQuietPeriodprivate longgracefulShutdownStartTimeprivate longgracefulShutdownTimeoutprivate booleaninterruptedprivate longlastExecutionTimeprivate static InternalLoggerloggerprivate intmaxPendingTasksprivate static java.lang.RunnableNOOP_TASKprivate static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<SingleThreadEventExecutor,ThreadProperties>PROPERTIES_UPDATERprivate RejectedExecutionHandlerrejectedExecutionHandlerprivate static longSCHEDULE_PURGE_INTERVALprivate java.util.Set<java.lang.Runnable>shutdownHooksprivate static intST_NOT_STARTEDprivate static intST_SHUTDOWNprivate static intST_SHUTTING_DOWNprivate static intST_STARTEDprivate static intST_TERMINATEDprivate intstateprivate static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<SingleThreadEventExecutor>STATE_UPDATERprivate java.util.Queue<java.lang.Runnable>taskQueueprivate Promise<?>terminationFutureprivate java.lang.Threadthreadprivate java.util.concurrent.CountDownLatchthreadLockprivate ThreadPropertiesthreadProperties-
Fields inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor
nextTaskId, scheduledTaskQueue, WAKEUP_TASK
-
Fields inherited from class io.netty.util.concurrent.AbstractEventExecutor
DEFAULT_SHUTDOWN_QUIET_PERIOD, DEFAULT_SHUTDOWN_TIMEOUT
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp)Create a new instanceprotectedSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)Create a new instanceprotectedSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, java.util.Queue<java.lang.Runnable> taskQueue, RejectedExecutionHandler rejectedHandler)protectedSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp)Create a new instanceprotectedSingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)Create a new instance
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidaddShutdownHook(java.lang.Runnable task)Add aRunnablewhich will be executed on shutdown of this instanceprotected voidaddTask(java.lang.Runnable task)Add a task to the task queue, or throws aRejectedExecutionExceptionif this instance was shutdown before.protected voidafterRunningAllTasks()Invoked before returning fromrunAllTasks()andrunAllTasks(long).booleanawaitTermination(long timeout, java.util.concurrent.TimeUnit unit)protected voidcleanup()Do nothing, sub-classes may overrideprotected booleanconfirmShutdown()Confirm that the shutdown if the instance should be done now!protected longdeadlineNanos()Returns the absolute point in time (relative toAbstractScheduledEventExecutor.nanoTime()) at which the the next closest scheduled task should run.protected longdelayNanos(long currentTimeNanos)Returns the amount of time left until the scheduled task with the closest dead line is executed.private voiddoStartThread()(package private) intdrainTasks()private booleanensureThreadStarted(int oldState)voidexecute(java.lang.Runnable task)private voidexecute(java.lang.Runnable task, boolean immediate)private booleanexecuteExpiredScheduledTasks()private booleanfetchFromScheduledTaskQueue()protected booleanhasTasks()booleaninEventLoop(java.lang.Thread thread)Returntrueif the givenThreadis executed in the event loop,falseotherwise.protected voidinterruptThread()Interrupt the current runningThread.<T> java.util.List<java.util.concurrent.Future<T>>invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)<T> java.util.List<java.util.concurrent.Future<T>>invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)<T> TinvokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)<T> TinvokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)booleanisShutdown()booleanisShuttingDown()Returnstrueif and only if allEventExecutors managed by thisEventExecutorGroupare being shut down gracefully or was shut down.booleanisTerminated()voidlazyExecute(java.lang.Runnable task)LikeExecutor.execute(Runnable)but does not guarantee the task will be run until either a non-lazy task is executed or the executor is shut down.protected java.util.Queue<java.lang.Runnable>newTaskQueue()Deprecated.Please use and overridenewTaskQueue(int).protected java.util.Queue<java.lang.Runnable>newTaskQueue(int maxPendingTasks)Create a newQueuewhich will holds the tasks to execute.(package private) booleanofferTask(java.lang.Runnable task)protected java.lang.RunnablepeekTask()intpendingTasks()Return the number of tasks that are pending for processing.protected java.lang.RunnablepollTask()protected static java.lang.RunnablepollTaskFrom(java.util.Queue<java.lang.Runnable> taskQueue)protected static voidreject()protected voidreject(java.lang.Runnable task)Offers the task to the associatedRejectedExecutionHandler.voidremoveShutdownHook(java.lang.Runnable task)Remove a previous addedRunnableas a shutdown hookprotected booleanremoveTask(java.lang.Runnable task)protected abstract voidrun()Run the tasks in thetaskQueueprotected booleanrunAllTasks()Poll all tasks from the task queue and run them viaRunnable.run()method.protected booleanrunAllTasks(long timeoutNanos)Poll all tasks from the task queue and run them viaRunnable.run()method.protected booleanrunAllTasksFrom(java.util.Queue<java.lang.Runnable> taskQueue)Runs all tasks from the passedtaskQueue.private booleanrunExistingTasksFrom(java.util.Queue<java.lang.Runnable> taskQueue)What ever tasks are present intaskQueuewhen this method is invoked will beRunnable.run().protected booleanrunScheduledAndExecutorTasks(int maxDrainAttempts)Execute all expired scheduled tasks and all current tasks in the executor queue until both queues are empty, ormaxDrainAttemptshas been exceeded.private booleanrunShutdownHooks()voidshutdown()Deprecated.Future<?>shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)Signals this executor that the caller wants the executor to be shut down.private voidstartThread()protected java.lang.RunnabletakeTask()Take the nextRunnablefrom the task queue and so will block if no task is currently present.Future<?>terminationFuture()Returns theFuturewhich is notified when allEventExecutors managed by thisEventExecutorGrouphave been terminated.ThreadPropertiesthreadProperties()private voidthrowIfInEventLoop(java.lang.String method)protected voidupdateLastExecutionTime()Updates the internal timestamp that tells when a submitted task was executed most recently.protected booleanwakesUpForTask(java.lang.Runnable task)Can be overridden to control which tasks require waking theEventExecutorthread if it is waiting so that they can be run immediately.protected voidwakeup(boolean inEventLoop)-
Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor
afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, peekScheduledTask, pollScheduledTask, pollScheduledTask, removeScheduled, schedule, schedule, scheduleAtFixedRate, scheduledTaskQueue, scheduleFromEventLoop, scheduleWithFixedDelay, validateScheduled
-
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
-
-
-
-
Field Detail
-
DEFAULT_MAX_PENDING_EXECUTOR_TASKS
static final int DEFAULT_MAX_PENDING_EXECUTOR_TASKS
-
logger
private static final InternalLogger logger
-
ST_NOT_STARTED
private static final int ST_NOT_STARTED
- See Also:
- Constant Field Values
-
ST_STARTED
private static final int ST_STARTED
- See Also:
- Constant Field Values
-
ST_SHUTTING_DOWN
private static final int ST_SHUTTING_DOWN
- See Also:
- Constant Field Values
-
ST_SHUTDOWN
private static final int ST_SHUTDOWN
- See Also:
- Constant Field Values
-
ST_TERMINATED
private static final int ST_TERMINATED
- See Also:
- Constant Field Values
-
NOOP_TASK
private static final java.lang.Runnable NOOP_TASK
-
STATE_UPDATER
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<SingleThreadEventExecutor> STATE_UPDATER
-
PROPERTIES_UPDATER
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<SingleThreadEventExecutor,ThreadProperties> PROPERTIES_UPDATER
-
taskQueue
private final java.util.Queue<java.lang.Runnable> taskQueue
-
thread
private volatile java.lang.Thread thread
-
threadProperties
private volatile ThreadProperties threadProperties
-
executor
private final java.util.concurrent.Executor executor
-
interrupted
private volatile boolean interrupted
-
threadLock
private final java.util.concurrent.CountDownLatch threadLock
-
shutdownHooks
private final java.util.Set<java.lang.Runnable> shutdownHooks
-
addTaskWakesUp
private final boolean addTaskWakesUp
-
maxPendingTasks
private final int maxPendingTasks
-
rejectedExecutionHandler
private final RejectedExecutionHandler rejectedExecutionHandler
-
lastExecutionTime
private long lastExecutionTime
-
state
private volatile int state
-
gracefulShutdownQuietPeriod
private volatile long gracefulShutdownQuietPeriod
-
gracefulShutdownTimeout
private volatile long gracefulShutdownTimeout
-
gracefulShutdownStartTime
private long gracefulShutdownStartTime
-
terminationFuture
private final Promise<?> terminationFuture
-
SCHEDULE_PURGE_INTERVAL
private static final long SCHEDULE_PURGE_INTERVAL
-
-
Constructor Detail
-
SingleThreadEventExecutor
protected SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp)
Create a new instance- Parameters:
parent- theEventExecutorGroupwhich is the parent of this instance and belongs to itthreadFactory- theThreadFactorywhich will be used for the usedThreadaddTaskWakesUp-trueif and only if invocation ofaddTask(Runnable)will wake up the executor thread
-
SingleThreadEventExecutor
protected SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.ThreadFactory threadFactory, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instance- Parameters:
parent- theEventExecutorGroupwhich is the parent of this instance and belongs to itthreadFactory- theThreadFactorywhich will be used for the usedThreadaddTaskWakesUp-trueif and only if invocation ofaddTask(Runnable)will wake up the executor threadmaxPendingTasks- the maximum number of pending tasks before new tasks will be rejected.rejectedHandler- theRejectedExecutionHandlerto use.
-
SingleThreadEventExecutor
protected SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp)
Create a new instance- Parameters:
parent- theEventExecutorGroupwhich is the parent of this instance and belongs to itexecutor- theExecutorwhich will be used for executingaddTaskWakesUp-trueif and only if invocation ofaddTask(Runnable)will wake up the executor thread
-
SingleThreadEventExecutor
protected SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
Create a new instance- Parameters:
parent- theEventExecutorGroupwhich is the parent of this instance and belongs to itexecutor- theExecutorwhich will be used for executingaddTaskWakesUp-trueif and only if invocation ofaddTask(Runnable)will wake up the executor threadmaxPendingTasks- the maximum number of pending tasks before new tasks will be rejected.rejectedHandler- theRejectedExecutionHandlerto use.
-
SingleThreadEventExecutor
protected SingleThreadEventExecutor(EventExecutorGroup parent, java.util.concurrent.Executor executor, boolean addTaskWakesUp, java.util.Queue<java.lang.Runnable> taskQueue, RejectedExecutionHandler rejectedHandler)
-
-
Method Detail
-
newTaskQueue
@Deprecated protected java.util.Queue<java.lang.Runnable> newTaskQueue()
Deprecated.Please use and overridenewTaskQueue(int).
-
newTaskQueue
protected java.util.Queue<java.lang.Runnable> newTaskQueue(int maxPendingTasks)
Create a newQueuewhich will holds the tasks to execute. This default implementation will return aLinkedBlockingQueuebut if your sub-class ofSingleThreadEventExecutorwill not do any blocking calls on the thisQueueit may make sense to@Overridethis and return some more performant implementation that does not support blocking operations at all.
-
interruptThread
protected void interruptThread()
Interrupt the current runningThread.
-
pollTask
protected java.lang.Runnable pollTask()
- See Also:
Queue.poll()
-
pollTaskFrom
protected static java.lang.Runnable pollTaskFrom(java.util.Queue<java.lang.Runnable> taskQueue)
-
takeTask
protected java.lang.Runnable takeTask()
Take the nextRunnablefrom the task queue and so will block if no task is currently present.Be aware that this method will throw an
UnsupportedOperationExceptionif the task queue, which was created vianewTaskQueue(), does not implementBlockingQueue.- Returns:
nullif the executor thread has been interrupted or waken up.
-
fetchFromScheduledTaskQueue
private boolean fetchFromScheduledTaskQueue()
-
executeExpiredScheduledTasks
private boolean executeExpiredScheduledTasks()
- Returns:
trueif at least one scheduled task was executed.
-
peekTask
protected java.lang.Runnable peekTask()
- See Also:
Queue.peek()
-
hasTasks
protected boolean hasTasks()
- See Also:
Collection.isEmpty()
-
pendingTasks
public int pendingTasks()
Return the number of tasks that are pending for processing. Be aware that this operation may be expensive as it depends on the internal implementation of the SingleThreadEventExecutor. So use it with care!
-
addTask
protected void addTask(java.lang.Runnable task)
Add a task to the task queue, or throws aRejectedExecutionExceptionif this instance was shutdown before.
-
offerTask
final boolean offerTask(java.lang.Runnable task)
-
removeTask
protected boolean removeTask(java.lang.Runnable task)
- See Also:
Collection.remove(Object)
-
runAllTasks
protected boolean runAllTasks()
Poll all tasks from the task queue and run them viaRunnable.run()method.- Returns:
trueif and only if at least one task was run
-
runScheduledAndExecutorTasks
protected final boolean runScheduledAndExecutorTasks(int maxDrainAttempts)
Execute all expired scheduled tasks and all current tasks in the executor queue until both queues are empty, ormaxDrainAttemptshas been exceeded.- Parameters:
maxDrainAttempts- The maximum amount of times this method attempts to drain from queues. This is to prevent continuous task execution and scheduling from preventing the EventExecutor thread to make progress and return to the selector mechanism to process inbound I/O events.- Returns:
trueif at least one task was run.
-
runAllTasksFrom
protected final boolean runAllTasksFrom(java.util.Queue<java.lang.Runnable> taskQueue)
Runs all tasks from the passedtaskQueue.- Parameters:
taskQueue- To poll and execute all tasks.- Returns:
trueif at least one task was executed.
-
runExistingTasksFrom
private boolean runExistingTasksFrom(java.util.Queue<java.lang.Runnable> taskQueue)
What ever tasks are present intaskQueuewhen this method is invoked will beRunnable.run().- Parameters:
taskQueue- the task queue to drain.- Returns:
trueif at leastRunnable.run()was called.
-
runAllTasks
protected boolean runAllTasks(long timeoutNanos)
Poll all tasks from the task queue and run them viaRunnable.run()method. This method stops running the tasks in the task queue and returns if it ran longer thantimeoutNanos.
-
afterRunningAllTasks
@UnstableApi protected void afterRunningAllTasks()
Invoked before returning fromrunAllTasks()andrunAllTasks(long).
-
delayNanos
protected long delayNanos(long currentTimeNanos)
Returns the amount of time left until the scheduled task with the closest dead line is executed.
-
deadlineNanos
@UnstableApi protected long deadlineNanos()
Returns the absolute point in time (relative toAbstractScheduledEventExecutor.nanoTime()) at which the the next closest scheduled task should run.
-
updateLastExecutionTime
protected void updateLastExecutionTime()
Updates the internal timestamp that tells when a submitted task was executed most recently.runAllTasks()andrunAllTasks(long)updates this timestamp automatically, and thus there's usually no need to call this method. However, if you take the tasks manually usingtakeTask()orpollTask(), you have to call this method at the end of task execution loop for accurate quiet period checks.
-
run
protected abstract void run()
Run the tasks in thetaskQueue
-
cleanup
protected void cleanup()
Do nothing, sub-classes may override
-
wakeup
protected void wakeup(boolean inEventLoop)
-
inEventLoop
public boolean inEventLoop(java.lang.Thread thread)
Description copied from interface:EventExecutorReturntrueif the givenThreadis executed in the event loop,falseotherwise.- Specified by:
inEventLoopin interfaceEventExecutor
-
addShutdownHook
public void addShutdownHook(java.lang.Runnable task)
Add aRunnablewhich will be executed on shutdown of this instance
-
removeShutdownHook
public void removeShutdownHook(java.lang.Runnable task)
Remove a previous addedRunnableas a shutdown hook
-
runShutdownHooks
private boolean runShutdownHooks()
-
shutdownGracefully
public Future<?> shutdownGracefully(long quietPeriod, long timeout, java.util.concurrent.TimeUnit unit)
Description copied from interface:EventExecutorGroupSignals this executor that the caller wants the executor to be shut down. Once this method is called,EventExecutorGroup.isShuttingDown()starts to returntrue, and the executor prepares to shut itself down. UnlikeEventExecutorGroup.shutdown(), graceful shutdown ensures that no tasks are submitted for 'the quiet period' (usually a couple seconds) before it shuts itself down. If a task is submitted during the quiet period, it is guaranteed to be accepted and the quiet period will start over.- Specified by:
shutdownGracefullyin interfaceEventExecutorGroup- Parameters:
quietPeriod- the quiet period as described in the documentationtimeout- the maximum amount of time to wait until the executor is EventExecutorGroup.shutdown() regardless if a task was submitted during the quiet periodunit- the unit ofquietPeriodandtimeout- Returns:
- the
EventExecutorGroup.terminationFuture()
-
terminationFuture
public Future<?> terminationFuture()
Description copied from interface:EventExecutorGroupReturns theFuturewhich is notified when allEventExecutors managed by thisEventExecutorGrouphave been terminated.- Specified by:
terminationFuturein interfaceEventExecutorGroup
-
shutdown
@Deprecated public void shutdown()
Deprecated.- Specified by:
shutdownin interfaceEventExecutorGroup- Specified by:
shutdownin interfacejava.util.concurrent.ExecutorService- Specified by:
shutdownin classAbstractEventExecutor
-
isShuttingDown
public boolean isShuttingDown()
Description copied from interface:EventExecutorGroupReturnstrueif and only if allEventExecutors managed by thisEventExecutorGroupare being shut down gracefully or was shut down.- Specified by:
isShuttingDownin interfaceEventExecutorGroup
-
isShutdown
public boolean isShutdown()
- Specified by:
isShutdownin interfacejava.util.concurrent.ExecutorService
-
isTerminated
public boolean isTerminated()
- Specified by:
isTerminatedin interfacejava.util.concurrent.ExecutorService
-
confirmShutdown
protected boolean confirmShutdown()
Confirm that the shutdown if the instance should be done now!
-
awaitTermination
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException- Specified by:
awaitTerminationin interfacejava.util.concurrent.ExecutorService- Throws:
java.lang.InterruptedException
-
execute
public void execute(java.lang.Runnable task)
- Specified by:
executein interfacejava.util.concurrent.Executor
-
lazyExecute
public void lazyExecute(java.lang.Runnable task)
Description copied from class:AbstractEventExecutorLikeExecutor.execute(Runnable)but does not guarantee the task will be run until either a non-lazy task is executed or the executor is shut down. This is equivalent to submitting aEventExecutor.LazyRunnabletoExecutor.execute(Runnable)but for an arbitraryRunnable. The default implementation just delegates toExecutor.execute(Runnable).- Overrides:
lazyExecutein classAbstractEventExecutor
-
execute
private void execute(java.lang.Runnable task, boolean immediate)
-
invokeAny
public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException- Specified by:
invokeAnyin interfacejava.util.concurrent.ExecutorService- Overrides:
invokeAnyin classjava.util.concurrent.AbstractExecutorService- Throws:
java.lang.InterruptedExceptionjava.util.concurrent.ExecutionException
-
invokeAny
public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException- Specified by:
invokeAnyin interfacejava.util.concurrent.ExecutorService- Overrides:
invokeAnyin classjava.util.concurrent.AbstractExecutorService- Throws:
java.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionjava.util.concurrent.TimeoutException
-
invokeAll
public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks) throws java.lang.InterruptedException- Specified by:
invokeAllin interfacejava.util.concurrent.ExecutorService- Overrides:
invokeAllin classjava.util.concurrent.AbstractExecutorService- Throws:
java.lang.InterruptedException
-
invokeAll
public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException- Specified by:
invokeAllin interfacejava.util.concurrent.ExecutorService- Overrides:
invokeAllin classjava.util.concurrent.AbstractExecutorService- Throws:
java.lang.InterruptedException
-
throwIfInEventLoop
private void throwIfInEventLoop(java.lang.String method)
-
threadProperties
public final ThreadProperties threadProperties()
Returns theThreadPropertiesof theThreadthat powers theSingleThreadEventExecutor. If theSingleThreadEventExecutoris not started yet, this operation will start it and block until it is fully started.
-
wakesUpForTask
protected boolean wakesUpForTask(java.lang.Runnable task)
Can be overridden to control which tasks require waking theEventExecutorthread if it is waiting so that they can be run immediately.
-
reject
protected static void reject()
-
reject
protected final void reject(java.lang.Runnable task)
Offers the task to the associatedRejectedExecutionHandler.- Parameters:
task- to reject.
-
startThread
private void startThread()
-
ensureThreadStarted
private boolean ensureThreadStarted(int oldState)
-
doStartThread
private void doStartThread()
-
drainTasks
final int drainTasks()
-
-