Class Summary Class Description AbstractAsyncTaskA base class for tasks that need to repeat. AbstractLifecycleRunnable
AbstractLifecycleRunnableis a service-lifecycle aware
AbstractRunnableAn extension to runnable. AsyncIOProcessor<Item>This async IO processor allows to batch IO operations and have a single writer processing the write operations. AtomicArray<E>A list backed by an
AtomicReferenceArraywith potential null values, easily allowing to get the concrete values as a list using
BaseFuture<V> ConcurrentCollections ConcurrentHashMapLong<T> CountDownA simple thread safe count-down class that in contrast to a
EsAbortPolicy EsExecutors EsThreadPoolExecutorAn extension to thread pool executor, allowing (in the future) to add specific additional stats to it. FutureUtils KeyedLock<T>This class manages locks. ListenableFuture<V>A future implementation that allows for the result to be passed to listeners waiting for notification. PrioritizedCallable<T> PrioritizedEsThreadPoolExecutorA prioritizing executor which uses a priority queue as a work queue. PrioritizedEsThreadPoolExecutor.Pending PrioritizedRunnable QueueResizingEsThreadPoolExecutorAn extension to thread pool executor, which automatically adjusts the queue size of the
ResizableBlockingQueueaccording to Little's Law.
ReleasableLockReleasable lock used inside of Engine implementations RunOnceRunnable that can only be run one time. SizeBlockingQueue<E>A size based queue wrapping another blocking queue to provide (somewhat relaxed) capacity checks. ThreadContextA ThreadContext is a map of string headers and a transient map of keyed objects that are associated with a thread.