Uses of Package
org.infinispan.util.concurrent
Package
Description
Cache
configurationData containers which store cache entries.
Implementations of different executors used for asynchronous operation.
Factories are internal components used to create other components based on a cache's
configuration.
Global configuration state.
Persistence API.
Soft Index
AdvancedLoadWriteStore
.The Persistence SPI.
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
-
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionDeprecated, for removal: This API element is subject to removal in a future version.
-
ClassDescriptionOrdering 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.
-
ClassDescriptionOrdering 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.
-
ClassDescriptionA special Runnable that is only sent to a thread when it is ready to be executed without blocking the threadExecutor service that is aware of
BlockingRunnable
and only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
.An acknowledge collector for Triangle algorithm used in non-transactional caches for write operations. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
.Manager utility for non-blocking operations. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
-
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
.Manager utility for non-blocking operations. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
.Manager utility for non-blocking operations. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that 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 ofBlockingRunnable
and only dispatch the runnable to a thread when it has low (or no) probability of blocking the thread.Deprecated, for removal: This API element is subject to removal in a future version.useIsolationLevel
insteadManager utility for non-blocking operations.A scheduled CompletionStage that may be cancelled if it has not been started yet. -
ClassDescriptionManager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage
orPublisher
that continues on the non-blocking executor, similar tostage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor)
.
IsolationLevel
instead