Package io.netty.util.concurrent
Utility classes for concurrent / async tasks.
-
Interface Summary Interface Description AbstractEventExecutor.LazyRunnable Marker interface forRunnableto indicate that it should be queued for execution but does not need to run immediately.EventExecutor TheEventExecutoris a specialEventExecutorGroupwhich comes with some handy methods to see if aThreadis executed in a event loop.EventExecutorChooserFactory Factory that creates newEventExecutorChooserFactory.EventExecutorChoosers.EventExecutorChooserFactory.EventExecutorChooser Chooses the nextEventExecutorto use.EventExecutorGroup TheEventExecutorGroupis responsible for providing theEventExecutor's to use via itsEventExecutorGroup.next()method.Future<V> The result of an asynchronous operation.FutureListener<V> A subtype ofGenericFutureListenerthat hides type parameter for convenience.GenericFutureListener<F extends Future<?>> Listens to the result of aFuture.GenericProgressiveFutureListener<F extends ProgressiveFuture<?>> OrderedEventExecutor Marker interface forEventExecutors that will process all submitted tasks in an ordered / serial fashion.ProgressiveFuture<V> AFuturewhich is used to indicate the progress of an operation.ProgressivePromise<V> SpecialProgressiveFuturewhich is writable.Promise<V> SpecialFuturewhich is writable.RejectedExecutionHandler Similar toRejectedExecutionHandlerbut specific toSingleThreadEventExecutor.ScheduledFuture<V> The result of an scheduled asynchronous operation.SingleThreadEventExecutor.NonWakeupRunnable Deprecated. ThreadProperties Expose details for aThread. -
Class Summary Class Description AbstractEventExecutor Abstract base class forEventExecutorimplementations.AbstractEventExecutorGroup Abstract base class forEventExecutorGroupimplementations.AbstractFuture<V> AbstractFutureimplementation which does not allow for cancellation.AbstractScheduledEventExecutor Abstract base class forEventExecutors that want to support scheduling.CompleteFuture<V> DefaultEventExecutor DefaultSingleThreadEventExecutorimplementation which just execute all submitted task in a serial fashion.DefaultEventExecutorChooserFactory Default implementation which uses simple round-robin to choose nextEventExecutor.DefaultEventExecutorChooserFactory.GenericEventExecutorChooser DefaultEventExecutorChooserFactory.PowerOfTwoEventExecutorChooser DefaultEventExecutorGroup Default implementation ofMultithreadEventExecutorGroupwhich will useDefaultEventExecutorinstances to handle the tasks.DefaultFutureListeners DefaultProgressivePromise<V> DefaultPromise<V> DefaultPromise.CauseHolder DefaultThreadFactory AThreadFactoryimplementation with a simple naming rule.FailedFuture<V> TheCompleteFuturewhich is failed already.FastThreadLocal<V> A special variant ofThreadLocalthat yields higher access performance when accessed from aFastThreadLocalThread.FastThreadLocalRunnable FastThreadLocalThread A specialThreadthat provides fast access toFastThreadLocalvariables.GlobalEventExecutor Single-thread singletonEventExecutor.ImmediateEventExecutor ExecutesRunnableobjects in the caller's thread.ImmediateEventExecutor.ImmediateProgressivePromise<V> ImmediateEventExecutor.ImmediatePromise<V> ImmediateExecutor Executorwhich execute tasks in the callers thread.MultithreadEventExecutorGroup Abstract base class forEventExecutorGroupimplementations that handles their tasks with multiple threads at the same time.NonStickyEventExecutorGroup EventExecutorGroupwhich will preserveRunnableexecution order but makes no guarantees about whatEventExecutor(and thereforeThread) will be used to execute theRunnables.NonStickyEventExecutorGroup.NonStickyOrderedEventExecutor 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>> GenericFutureListenerimplementation which takes otherPromises and notifies them on completion.PromiseTask<V> PromiseTask.RunnableAdapter<T> PromiseTask.SentinelRunnable RejectedExecutionHandlers Expose helper methods which create differentRejectedExecutionHandlers.ScheduledFutureTask<V> SingleThreadEventExecutor Abstract base class forOrderedEventExecutor's that execute all its submitted tasks in a single thread.SingleThreadEventExecutor.DefaultThreadProperties SucceededFuture<V> TheCompleteFuturewhich is succeeded already.ThreadPerTaskExecutor UnaryPromiseNotifier<T> UnorderedThreadPoolEventExecutor EventExecutorimplementation which makes no guarantees about the ordering of task execution that are submitted because there may be multiple threads executing these tasks.UnorderedThreadPoolEventExecutor.NonNotifyRunnable UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V> -
Exception Summary Exception Description BlockingOperationException AnIllegalStateExceptionwhich is raised when a user performed a blocking operation when the user is in an event loop thread.DefaultPromise.LeanCancellationException