Package org.infinispan.commons.util.concurrent
package org.infinispan.commons.util.concurrent
Provides commons interfaces and classes related to concurrency
- Public API
-
ClassDescriptionAggregation 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.A handler for rejected tasks that runs the task if the current thread is a blocking thread otherwise it rejects the task.ACacheExceptionthat is thrown when the backpressure has been filled an unable to process the request.A handler for rejected tasks that runs the rejected task directly in the calling thread of theexecutemethod.Utility methods connectingCompletableFuturefutures.Utility methods for handlingCompletionStageinstances.A simplified global lock backed by the file system.A handler for rejected tasks that always throws aIllegalLifecycleStateException.A handler for rejected tasks that runs the task if the current thread is a non blocking thread otherwise it blocks until the task can be added to the underlying queueA simplistic non-reentrant lock that does not use ownership by thread.Duplicates a set of counters in a set of stripes, so that multiple threads can increment those counters without too much contention.