Package io.netty.util.concurrent
Utility classes for concurrent / async tasks.
-
Interface Summary Interface Description AbstractEventExecutor.LazyRunnable Deprecated. overrideSingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable)
to re-create this behaviourEventExecutor TheEventExecutor
is a specialEventExecutorGroup
which comes with some handy methods to see if aThread
is executed in a event loop.EventExecutorChooserFactory Factory that creates newEventExecutorChooserFactory.EventExecutorChooser
s.EventExecutorChooserFactory.EventExecutorChooser Chooses the nextEventExecutor
to use.EventExecutorGroup TheEventExecutorGroup
is responsible for providing theEventExecutor
's to use via itsEventExecutorGroup.next()
method.Future<V> The result of an asynchronous operation.FutureListener<V> A subtype ofGenericFutureListener
that hides type parameter for convenience.GenericFutureListener<F extends Future<?>> Listens to the result of aFuture
.GenericProgressiveFutureListener<F extends ProgressiveFuture<?>> OrderedEventExecutor Marker interface forEventExecutor
s that will process all submitted tasks in an ordered / serial fashion.ProgressiveFuture<V> AFuture
which is used to indicate the progress of an operation.ProgressivePromise<V> SpecialProgressiveFuture
which is writable.Promise<V> SpecialFuture
which is writable.RejectedExecutionHandler Similar toRejectedExecutionHandler
but specific toSingleThreadEventExecutor
.ScheduledFuture<V> The result of a scheduled asynchronous operation.SingleThreadEventExecutor.NonWakeupRunnable Deprecated. overrideSingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable)
to re-create this behaviourThreadAwareExecutor Executor that is aware its execution thread.ThreadProperties Expose details for aThread
. -
Class Summary Class Description AbstractEventExecutor Abstract base class forEventExecutor
implementations.AbstractEventExecutorGroup Abstract base class forEventExecutorGroup
implementations.AbstractFuture<V> AbstractFuture
implementation which does not allow for cancellation.AbstractScheduledEventExecutor Abstract base class forEventExecutor
s that want to support scheduling.CompleteFuture<V> DefaultEventExecutor DefaultSingleThreadEventExecutor
implementation which just execute all submitted task in a serial fashion.DefaultEventExecutorChooserFactory Default implementation which uses simple round-robin to choose nextEventExecutor
.DefaultEventExecutorGroup Default implementation ofMultithreadEventExecutorGroup
which will useDefaultEventExecutor
instances to handle the tasks.DefaultProgressivePromise<V> DefaultPromise<V> DefaultThreadFactory AThreadFactory
implementation with a simple naming rule.FailedFuture<V> TheCompleteFuture
which is failed already.FastThreadLocal<V> A special variant ofThreadLocal
that yields higher access performance when accessed from aFastThreadLocalThread
.FastThreadLocalThread A specialThread
that provides fast access toFastThreadLocal
variables.GlobalEventExecutor Single-thread singletonEventExecutor
.ImmediateEventExecutor ExecutesRunnable
objects in the caller's thread.ImmediateExecutor Executor
which execute tasks in the callers thread.MultithreadEventExecutorGroup Abstract base class forEventExecutorGroup
implementations that handles their tasks with multiple threads at the same time.NonStickyEventExecutorGroup EventExecutorGroup
which will preserveRunnable
execution order but makes no guarantees about whatEventExecutor
(and thereforeThread
) will be used to execute theRunnable
s.PromiseAggregator<V,F extends Future<V>> Deprecated. PromiseCombiner A promise combiner monitors the outcome of a number of discrete futures, then notifies a final, aggregate promise when all of the combined futures are finished.PromiseNotifier<V,F extends Future<V>> GenericFutureListener
implementation which takes otherPromise
s and notifies them on completion.RejectedExecutionHandlers Expose helper methods which create differentRejectedExecutionHandler
s.SingleThreadEventExecutor Abstract base class forOrderedEventExecutor
's that execute all its submitted tasks in a single thread.SucceededFuture<V> TheCompleteFuture
which is succeeded already.ThreadPerTaskExecutor UnaryPromiseNotifier<T> Deprecated. UnorderedThreadPoolEventExecutor Deprecated. The behavior of this event executor deviates from the typical Netty execution model and can cause subtle issues as a result. -
Exception Summary Exception Description BlockingOperationException AnIllegalStateException
which is raised when a user performed a blocking operation when the user is in an event loop thread.