ClassDescriptionA base class for tasks that need to repeat.
AbstractLifecycleRunnableis a service-lifecycle aware
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
AtomicReferenceArraywith potential null values, easily allowing to get the concrete values as a list using
AtomicArray.asList().BaseFuture<V>A simple thread safe count-down class that in contrast to a
CountDownLatchnever 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.We expect the work queue to be empty fairly frequently; if the queue remains nonempty for sufficiently long then there's a risk that some lower-priority tasks are being starved of access to the executor.An extension to thread pool executor, which automatically adjusts the queue size of the
ResizableBlockingQueueaccording 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.