Package org.elasticsearch.common.util.concurrent
package org.elasticsearch.common.util.concurrent
-
Interface Summary
-
Class SummaryClassDescriptionA base class for tasks that need to repeat.
AbstractLifecycleRunnableis a service-lifecycle awareAbstractRunnable.An 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 anAtomicReferenceArraywith potential null values, easily allowing to get the concrete values as a list usingAtomicArray.asList().BaseFuture<V>A simple thread safe count-down class that in contrast to aCountDownLatchnever blocks.An extension to thread pool executor, allowing (in the future) to add specific additional stats to it.KeyedLock<T>This class manages locks.A future implementation that allows for the result to be passed to listeners waiting for notification.A prioritizing executor which uses a priority queue as a work queue.An extension to thread pool executor, which automatically adjusts the queue size of theResizableBlockingQueueaccording to Little's Law.Releasable lock used inside of Engine implementationsRunnable that can only be run one time.A size based queue wrapping another blocking queue to provide (somewhat relaxed) capacity checks.A ThreadContext is a map of string headers and a transient map of keyed objects that are associated with a thread. -
Exception Summary