io.netty.util.concurrent

Interface PausableEventExecutor

All Superinterfaces:

AutoCloseable, EventExecutor, EventExecutorGroup, Executor, ExecutorService, ScheduledExecutorService, WrappedEventExecutor

public interface PausableEventExecutor
extends EventExecutor, WrappedEventExecutor

Implement this interface if you need your EventExecutor implementation to be able to reject new work.

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptNewTasks() With a call to this method the EventExecutor signals that it is now accepting new work.
boolean	isAcceptingNewTasks() Returns true if and only if this EventExecutor is accepting a new task.
void	rejectNewTasks() After a call to this method the EventExecutor may throw a RejectedExecutionException when attempting to assign new work to it (i.e. through a call to Executor.execute(Runnable)).

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

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

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

isShuttingDown, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

rejectNewTasks

void rejectNewTasks()

After a call to this method the EventExecutor may throw a RejectedExecutionException when attempting to assign new work to it (i.e. through a call to Executor.execute(Runnable)).

acceptNewTasks

void acceptNewTasks()

With a call to this method the EventExecutor signals that it is now accepting new work.

isAcceptingNewTasks

boolean isAcceptingNewTasks()

Returns true if and only if this EventExecutor is accepting a new task.