Package io.netty.util.concurrent

package io.netty.util.concurrent

Utility classes for concurrent / async tasks.

Related Packages

Package	Description
io.netty.util	Utility classes used across multiple packages.
io.netty.util.collection
io.netty.util.internal	Internal-use-only utilities which is not allowed to be used outside Netty.
io.netty.util.test	Test utilities for netty-common.

Class	Description
AbstractEventExecutor	Abstract base class for EventExecutor implementations.
AbstractEventExecutor.LazyRunnable	Deprecated. override SingleThreadEventExecutor.wakesUpForTask(Runnable) to re-create this behaviour
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.
AutoScalingEventExecutorChooserFactory	A factory that creates auto-scaling EventExecutorChooserFactory.EventExecutorChooser instances.
AutoScalingEventExecutorChooserFactory.AutoScalingUtilizationMetric	A container for the utilization metric of a single EventExecutor.
BlockingOperationException	An IllegalStateException which is raised when a user performed a blocking operation when the user is in an event loop thread.
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.
DefaultEventExecutorChooserFactory	Default implementation which uses simple round-robin to choose next EventExecutor.
DefaultEventExecutorGroup	Default implementation of MultithreadEventExecutorGroup which will use DefaultEventExecutor instances to handle the tasks.
DefaultProgressivePromise<V>
DefaultPromise<V>
DefaultThreadFactory	A ThreadFactory implementation with a simple naming rule.
EventExecutor	The EventExecutor is a special EventExecutorGroup which comes with some handy methods to see if a Thread is executed in a event loop.
EventExecutorChooserFactory	Factory that creates new EventExecutorChooserFactory.EventExecutorChoosers.
EventExecutorChooserFactory.EventExecutorChooser	Chooses the next EventExecutor to use.
EventExecutorChooserFactory.ObservableEventExecutorChooser	An EventExecutorChooserFactory.EventExecutorChooser that exposes metrics for observation.
EventExecutorGroup	The EventExecutorGroup is responsible for providing the EventExecutor's to use via its EventExecutorGroup.next() method.
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.
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<?>>
GlobalEventExecutor	Single-thread singleton EventExecutor.
ImmediateEventExecutor	Executes Runnable objects in the caller's thread.
ImmediateExecutor	Executor which execute tasks in the callers thread.
MockTicker	A fake Ticker that allows the caller control the flow of time.
MpscIntQueue	A multi-producer (concurrent and thread-safe offer and fill), single-consumer (single-threaded poll and drain) queue of primitive integers.
MpscIntQueue.MpscAtomicIntegerArrayQueue	This implementation is based on MpscAtomicUnpaddedArrayQueue from JCTools.
MultithreadEventExecutorGroup	Abstract base class for EventExecutorGroup implementations that handles their tasks with multiple threads at the same time.
NonStickyEventExecutorGroup	EventExecutorGroup which will preserve Runnable execution order but makes no guarantees about what EventExecutor (and therefore Thread) will be used to execute the Runnables.
OrderedEventExecutor	Marker interface for EventExecutors that will process all submitted tasks in an ordered / serial fashion.
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.
PromiseAggregator<V, F extends Future<V>>	Deprecated. Use PromiseCombiner(EventExecutor).
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 other Promises and notifies them on completion.
RejectedExecutionHandler	Similar to RejectedExecutionHandler but specific to SingleThreadEventExecutor.
RejectedExecutionHandlers	Expose helper methods which create different RejectedExecutionHandlers.
ScheduledFuture<V>	The result of a scheduled asynchronous operation.
SingleThreadEventExecutor	Abstract base class for OrderedEventExecutor's that execute all its submitted tasks in a single thread.
SingleThreadEventExecutor.NonWakeupRunnable	Deprecated. override SingleThreadEventExecutor.wakesUpForTask(Runnable) to re-create this behaviour
SucceededFuture<V>	The CompleteFuture which is succeeded already.
ThreadAwareExecutor	Executor that is aware its execution thread.
ThreadPerTaskExecutor
ThreadProperties	Expose details for a Thread.
Ticker	A nanosecond-based time source, e.g.
UnaryPromiseNotifier<T>	Deprecated. use PromiseNotifier.cascade(boolean, Future, Promise).
UnorderedThreadPoolEventExecutor	Deprecated. The behavior of this event executor deviates from the typical Netty execution model and can cause subtle issues as a result.