An interface for objects that need to be notified when all reference to itself are not in user anymore.
A basic RefCounted implementation that is initialized with a ref count of 1 and calls
An extension to runnable.
This async IO processor allows to batch IO operations and have a single writer processing the write operations.
A list backed by an
A simple thread safe count-down class that in contrast to a
An extension to thread pool executor, allowing (in the future) to add specific additional stats to it.
This class manages locks.
A prioritizing executor which uses a priority queue as a work queue.
Releasable lock used inside of Engine implementations
A size based queue wrapping another blocking queue to provide (somewhat relaxed) capacity checks.
A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.
A Barrier action to be used in conjunction with
A ThreadContext is a map of string headers and a transient map of keyed objects that are associated with a thread.