Package org.infinispan.util.concurrent

Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.

See: Description

Interface Summary

Interface	Description
AggregateCompletionStage<R>	Aggregation of multiple CompletionStage instances where their count is not known or when a large amount of stages are required, as it uses less memory foot print per stage.
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
BlockingManager.BlockingExecutor	Executor interface that submits task to a blocking pool that returns a stage that is guaranteed to run any chained stages on a non-blocking thread if the stage is not yet complete.
BlockingRunnable	A special Runnable that is only sent to a thread when it is ready to be executed without blocking the thread Used in org.infinispan.util.concurrent.BlockingTaskAwareExecutorService
BlockingTaskAwareExecutorService	Executor service that is aware of BlockingRunnable and only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread.
CommandAckCollector.MultiTargetCollector
NonBlockingManager	Manager utility for non-blocking operations.

Class Summary

Class	Description
ActionSequencer	Orders multiple actions/tasks based on a key.
BlockingManagerImpl
BlockingTaskAwareExecutorServiceImpl	A special executor service that accepts a BlockingRunnable.
BoundedExecutors	Similar to JDK Executors except that the factory methods here allow you to specify the size of the blocking queue that backs the executor.
CommandAckCollector	An acknowledge collector for Triangle algorithm used in non-transactional caches for write operations.
CompletableFutures	Utility methods connecting CompletableFuture futures.
CompletionStages	Utility methods for handling CompletionStage instances.
ConditionFuture<T>	A mixture between a CompletableFuture and a Condition.
CorePackageImpl
DataOperationOrderer	Ordering 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.
NonBlockingManagerImpl
ReclosableLatch	A thread gate, that uses an AbstractQueuedSynchronizer.
SynchronizedRestarter	A class that handles restarts of components via multiple threads.
WithinThreadExecutor	An executor that works within the current thread.

Enum Summary

Enum	Description
DataOperationOrderer.Operation
IsolationLevel	Various transaction isolation levels as an enumerated class.

Exception Summary

Exception	Description
TimeoutException	Thrown when a timeout occurred.

Package org.infinispan.util.concurrent Description

Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.