Package io.netty.util.concurrent

Utility classes for concurrent / async tasks.

See: Description

Interface Summary

Interface	Description
EventExecutor	The EventExecutor is a special EventExecutorGroup which comes with some handy methods to see if a Thread is executed in a event loop.
EventExecutorGroup	The EventExecutorGroup is responsible for providing the EventExecutor's to use via its EventExecutorGroup.next() method.
ExecutorServiceFactory	An object that creates new ExecutorService on demand.
FastThreadLocalAccess	Netty's Thread implementations implement this interface to provide fast access to FastThreadLocal variables.
Future<V>	The result of an asynchronous operation.
FutureListener<V>	A subtype of GenericFutureListener that hides type parameter for convenience.
GenericFutureListener<F extends Future<?>>	Listens to the result of a Future.
GenericProgressiveFutureListener<F extends ProgressiveFuture<?>>
PausableEventExecutor	Implement this interface if you need your EventExecutor implementation to be able to reject new work.
ProgressiveFuture<V>	A Future which is used to indicate the progress of an operation.
ProgressivePromise<V>	Special ProgressiveFuture which is writable.
Promise<V>	Special Future which is writable.
ScheduledFuture<V>	The result of an scheduled asynchronous operation.
WrappedEventExecutor	A marker interface indicating that the EventExecutor is a wrapper around another EventExecutor implementation.

Class Summary

Class	Description
AbstractEventExecutor	Abstract base class for EventExecutor implementations.
AbstractEventExecutorGroup	Abstract base class for EventExecutorGroup implementations.
AbstractFuture<V>	Abstract Future implementation which does not allow for cancellation.
AbstractScheduledEventExecutor	Abstract base class for EventExecutors that want to support scheduling.
CompleteFuture<V>	A skeletal Future implementation which represents a Future which has been completed already.
DefaultEventExecutor	Default SingleThreadEventExecutor implementation which just execute all submitted task in a serial fashion.
DefaultEventExecutorGroup	Default implementation of MultithreadEventExecutorGroup which will use DefaultEventExecutor instances to handle the tasks.
DefaultExecutorServiceFactory	An implementation of an ExecutorServiceFactory that creates a new ForkJoinPool on each call to DefaultExecutorServiceFactory.newExecutorService(int).
DefaultProgressivePromise<V>
DefaultPromise<V>
DefaultThreadFactory	A ThreadFactory implementation with a simple naming rule.
FailedFuture<V>	The CompleteFuture which is failed already.
FastThreadLocal<V>	A special variant of ThreadLocal that yields higher access performance when accessed from a FastThreadLocalThread.
FastThreadLocalThread	A special Thread that provides fast access to FastThreadLocal variables.
GlobalEventExecutor	Single-thread singleton EventExecutor.
ImmediateEventExecutor	AbstractEventExecutor which execute tasks in the callers thread.
ImmediateExecutor	Executor which execute tasks in the callers thread.
MultithreadEventExecutorGroup	Abstract base class for EventExecutorGroup implementations that handles their tasks with multiple threads at the same time.
PromiseAggregator<V,F extends Future<V>>	GenericFutureListener implementation which consolidates multiple Futures into one, by listening to individual Futures and producing an aggregated result (success/failure) when all Futures have completed.
PromiseNotifier<V,F extends Future<V>>	GenericFutureListener implementation which takes other Futures and notifies them on completion.
SingleThreadEventExecutor	Abstract base class for EventExecutor's that execute all its submitted tasks in a single thread.
SucceededFuture<V>	The CompleteFuture which is succeeded already.
ThreadPerTaskExecutor

Exception Summary

Exception	Description
BlockingOperationException	An IllegalStateException which is raised when a user performed a blocking operation when the user is in an event loop thread.

Package io.netty.util.concurrent Description

Utility classes for concurrent / async tasks.