| Interface | Description |
|---|---|
| ConcurrentMapLong<T> | |
| EsThreadPoolExecutor.ShutdownListener | |
| RefCounted |
An interface for objects that need to be notified when all reference
to itself are not in user anymore.
|
| ThreadContext.StoredContext | |
| XRejectedExecutionHandler |
| Class | Description |
|---|---|
| AbstractLifecycleRunnable |
AbstractLifecycleRunnable is a service-lifecycle aware AbstractRunnable. |
| AbstractRefCounted |
A basic RefCounted implementation that is initialized with a
ref count of 1 and calls
AbstractRefCounted.closeInternal() once it reaches
a 0 ref count |
| AbstractRunnable |
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 an
AtomicReferenceArray with potential null values, easily allowing
to get the concrete values as a list using AtomicArray.asList(). |
| BaseFuture<V> | |
| ConcurrentCollections | |
| ConcurrentHashMapLong<T> | |
| CountDown |
A simple thread safe count-down class that in contrast to a
CountDownLatch
never blocks. |
| EsAbortPolicy | |
| EsExecutors | |
| EsThreadPoolExecutor |
An extension to thread pool executor, allowing (in the future) to add specific additional stats to it.
|
| FutureUtils | |
| KeyedLock<T> |
This class manages locks.
|
| LoggingRunnable | |
| PrioritizedCallable<T> | |
| PrioritizedEsThreadPoolExecutor |
A prioritizing executor which uses a priority queue as a work queue.
|
| PrioritizedEsThreadPoolExecutor.Pending | |
| PrioritizedRunnable | |
| QueueResizingEsThreadPoolExecutor |
An extension to thread pool executor, which automatically adjusts the queue size of the
ResizableBlockingQueue according to Little's Law. |
| ReleasableLock |
Releasable lock used inside of Engine implementations
|
| SizeBlockingQueue<E> |
A size based queue wrapping another blocking queue to provide (somewhat relaxed) capacity checks.
|
| ThreadBarrier |
A synchronization aid that allows a set of threads to all wait for each other
to reach a common barrier point.
|
| ThreadBarrier.BarrierTimer |
A Barrier action to be used in conjunction with
ThreadBarrier to
measure performance between barrier awaits. |
| ThreadContext |
A ThreadContext is a map of string headers and a transient map of keyed objects that are associated with
a thread.
|
| Exception | Description |
|---|---|
| EsRejectedExecutionException | |
| UncategorizedExecutionException |