Module org.elasticsearch.server
Package org.elasticsearch.common.util.concurrent
package org.elasticsearch.common.util.concurrent
-
ClassDescriptionA base class for tasks that need to repeat.An extension to runnable.
AbstractThrottledTaskRunner
runs the enqueued tasks using the given executor, limiting the number of tasks that are submitted to the executor at once.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 anAtomicReferenceArray
with potential null values, easily allowing to get the concrete values as a list usingAtomicArray.asList()
.A simple thread-safe count-down class that does not block, unlike aCountDownLatch
.A collection of static methods to help create different ES Executor types.An extension to thread pool executor, allowing (in the future) to add specific additional stats to it.KeyedLock<T>This class manages locks.AnActionListener
which allows for the result to fan out to a (dynamic) collection of other listeners, added usingSubscribableListener.addListener(org.elasticsearch.action.ActionListener<T>)
.A prioritizing executor which uses a priority queue as a work queue.PrioritizedThrottledTaskRunner
performs the enqueued tasks in the order dictated by the natural ordering of the tasks, limiting the max number of concurrently running tasks.Releasable lock used inside of Engine implementationsRunnable that prevents running its delegate more than once.A size based queue wrapping another blocking queue to provide (somewhat relaxed) capacity checks.An extension to thread pool executor, which tracks statistics for the task execution time.A ThreadContext is a map of string headers and a transient map of keyed objects that are associated with a thread.