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 the
executemethod.Utility methods connecting
CompletableFuturefutures.A handler for rejected tasks that always throws a
IllegalLifecycleStateException.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.