Package io.netty.util.concurrent
package io.netty.util.concurrent
Utility classes for concurrent / async tasks.
-
ClassDescriptionAbstract base class for
EventExecutor
implementations.Deprecated.Abstract base class forEventExecutorGroup
implementations.AbstractFuture
implementation which does not allow for cancellation.Abstract base class forEventExecutor
s that want to support scheduling.AnIllegalStateException
which is raised when a user performed a blocking operation when the user is in an event loop thread.DefaultSingleThreadEventExecutor
implementation which just execute all submitted task in a serial fashion.Default implementation which uses simple round-robin to choose nextEventExecutor
.Default implementation ofMultithreadEventExecutorGroup
which will useDefaultEventExecutor
instances to handle the tasks.AThreadFactory
implementation with a simple naming rule.TheEventExecutor
is a specialEventExecutorGroup
which comes with some handy methods to see if aThread
is executed in a event loop.Factory that creates newEventExecutorChooserFactory.EventExecutorChooser
s.Chooses the nextEventExecutor
to use.TheEventExecutorGroup
is responsible for providing theEventExecutor
's to use via itsEventExecutorGroup.next()
method.FailedFuture<V>TheCompleteFuture
which is failed already.A special variant ofThreadLocal
that yields higher access performance when accessed from aFastThreadLocalThread
.A specialThread
that provides fast access toFastThreadLocal
variables.Future<V>The result of an asynchronous operation.A subtype ofGenericFutureListener
that hides type parameter for convenience.GenericFutureListener<F extends Future<?>>Listens to the result of aFuture
.GenericProgressiveFutureListener<F extends ProgressiveFuture<?>>Single-thread singletonEventExecutor
.ExecutesRunnable
objects in the caller's thread.Executor
which execute tasks in the callers thread.Abstract base class forEventExecutorGroup
implementations that handles their tasks with multiple threads at the same time.EventExecutorGroup
which will preserveRunnable
execution order but makes no guarantees about whatEventExecutor
(and thereforeThread
) will be used to execute theRunnable
s.Marker interface forEventExecutor
s that will process all submitted tasks in an ordered / serial fashion.AFuture
which is used to indicate the progress of an operation.SpecialProgressiveFuture
which is writable.Promise<V>SpecialFuture
which is writable.PromiseAggregator<V,F extends Future<V>> Deprecated.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.PromiseTask<V>Similar toRejectedExecutionHandler
but specific toSingleThreadEventExecutor
.Expose helper methods which create differentRejectedExecutionHandler
s.The result of a scheduled asynchronous operation.Abstract base class forOrderedEventExecutor
's that execute all its submitted tasks in a single thread.Deprecated.overrideSingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable)
to re-create this behaviourTheCompleteFuture
which is succeeded already.Expose details for aThread
.Deprecated.EventExecutor
implementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks.
SingleThreadEventExecutor.wakesUpForTask(java.lang.Runnable)
to re-create this behaviour