Package org.infinispan.util.concurrent
package org.infinispan.util.concurrent
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
-
ClassDescriptionOrders multiple actions/tasks based on a key.Manager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStageorPublisherthat continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).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.A special Runnable that is only sent to a thread when it is ready to be executed without blocking the threadExecutor service that is aware ofBlockingRunnableand only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread.A special executor service that accepts aBlockingRunnable.An acknowledge collector for Triangle algorithm used in non-transactional caches for write operations.A mixture between aCompletableFutureand aCondition.A concurrency structure that invokes aRunnablewhen its count reaches zero.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.Deprecated, for removal: This API element is subject to removal in a future version.Manager utility for non-blocking operations.A thread gate, that uses anAbstractQueuedSynchronizer.A scheduled CompletionStage that may be cancelled if it has not been started yet.An executor that works within the current thread.
IsolationLevelinstead