Utility classes for concurrent / async tasks.
Interface Summary Interface Description EventExecutorThe
EventExecutoris a special
EventExecutorGroupwhich comes with some handy methods to see if a
Threadis executed in a event loop.
EventExecutorGroupis responsible for providing the
EventExecutor's to use via its
Future<V>The result of an asynchronous operation. FutureCompletionStage<V>A
CompletionStagethat provides the same threading semantics and guarantees as the underlying
Future, which means that all the callbacks will be executed by
FutureCompletionStage.executor()if not specified otherwise (by calling the corresponding *Async methods).
FutureContextListener<C,V>Listens to the result of a
FutureListener<V>Listens to the result of a
FuturePromiseFactory OrderedEventExecutorMarker interface for
EventExecutors that will process all submitted tasks in an ordered / serial fashion.
Futurewhich is writable.
RejectedExecutionHandlerbut specific to
RunnableFuture<V>A combination of
RunnableScheduledFuture<V>A combination of
Comparable(sorting by their next deadline), with additional methods for scheduling, periodicity, and delay.
ThreadPropertiesExpose details for a
Class Summary Class Description AbstractEventExecutorAbstract base class for
AbstractScheduledEventExecutorAbstract base class for
EventExecutors that want to support scheduling.
DefaultEventExecutorGroupDefault implementation of
MultithreadEventExecutorGroupwhich will use
SingleThreadEventExecutorinstances to handle the tasks.
ThreadFactoryimplementation with a simple naming rule.
FastThreadLocal<V>A special variant of
ThreadLocalthat yields higher access performance when accessed from a
Threadthat provides fast access to
Runnableobjects in the caller's thread.
Executorwhich execute tasks in the callers thread.
EventExecutorGroupimplementation that handles their tasks with multiple threads at the same time.
EventExecutorGroupwhich will preserve
Runnableexecution order but makes no guarantees about what
Thread) will be used to execute the
PromiseCombinerA 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. RejectedExecutionHandlersExpose helper methods which create different
OrderedEventExecutor's implementation that execute all its submitted tasks in a single thread.
EventExecutorimplementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks.
Exception Summary Exception Description BlockingOperationExceptionAn
IllegalStateExceptionwhich is raised when a user performed a blocking operation when the user is in an event loop thread.