Package org.infinispan.util.concurrent
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
-
Interface Summary Interface Description BlockingRunnable A 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 threadBlockingTaskAwareExecutorService Executor service that is aware ofBlockingRunnable
and only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread.CommandAckCollector.MultiTargetCollector -
Class Summary Class Description BlockingTaskAwareExecutorServiceImpl A special executor service that accepts aBlockingRunnable
.BoundedExecutors Similar to JDKExecutors
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 connectingCompletableFuture
futures.ReclosableLatch A thread gate, that uses anAbstractQueuedSynchronizer
.StripedCounters<T> Duplicates a set of counters in a set of stripes, so that multiple threads can increment those counters without too much contention.SynchronizedRestarter A class that handles restarts of components via multiple threads.WithinThreadExecutor An executor that works within the current thread. -
Enum Summary Enum Description IsolationLevel Various transaction isolation levels as an enumerated class. -
Exception Summary Exception Description TimeoutException Thrown when a timeout occurred.