Package org.infinispan.commons.util.concurrent
package org.infinispan.commons.util.concurrent
Provides commons interfaces and classes related to concurrency
- Public API
-
ClassDescriptionA handler for rejected tasks that runs the task if the current thread is a blocking thread otherwise it rejects the task.A
CacheExceptionthat 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.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.