Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.
Interface Summary Interface Description AggregateCompletionStage<R>Aggregation of multiple
CompletionStageinstances where their count is not known or when a large amount of stages are required, as it uses less memory foot print per stage.
BlockingRunnableA special Runnable (for the particular case of Total Order) that is only sent to a thread when it is ready to be executed without blocking the thread BlockingTaskAwareExecutorServiceExecutor service that is aware of
BlockingRunnableand only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread.
Class Summary Class Description ActionSequencerOrders multiple actions/tasks based on a key. BlockingTaskAwareExecutorServiceImplA special executor service that accepts a
BoundedExecutorsSimilar to JDK
Executorsexcept that the factory methods here allow you to specify the size of the blocking queue that backs the executor.
CommandAckCollectorAn acknowledge collector for Triangle algorithm used in non-transactional caches for write operations. CompletableFuturesUtility methods connecting
CompletionStagesUtility methods for handling
CorePackageImpl DataOperationOrdererOrdering construct allowing concurrent operations that wish to do operations upon the same key to wait until the most recently registered operation is complete in a non blocking way. ReclosableLatchA thread gate, that uses an
SynchronizedRestarterA class that handles restarts of components via multiple threads. WithinThreadExecutorAn executor that works within the current thread.
Enum Summary Enum Description DataOperationOrderer.Operation IsolationLevelVarious transaction isolation levels as an enumerated class.
Exception Summary Exception Description TimeoutExceptionThrown when a timeout occurred.