Uses of Package
org.infinispan.util.concurrent
Packages that use 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
NonBlockingStore
.The Persistence SPI.
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
-
Classes in org.infinispan.util.concurrent used by org.infinispan.cache.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.configuration.cacheClassDescriptionDeprecated, for removal: This API element is subject to removal in a future version.
-
Classes in org.infinispan.util.concurrent used by org.infinispan.container.implClassDescriptionOrdering 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.
-
Classes in org.infinispan.util.concurrent used by org.infinispan.container.offheapClassDescriptionOrdering 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.
-
Classes in org.infinispan.util.concurrent used by org.infinispan.executorsClassDescriptionA 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.factoriesClassDescriptionManager 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.globalstateClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.globalstate.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.manager.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.persistenceClassDescriptionManager 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.jdbc.common.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.sifs
-
Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.spiClassDescriptionManager 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.supportClassDescriptionManager 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.query.concurrentClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.mappingClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.mapping.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.work.implClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.server.coreClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.adminClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.backupClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.backup.resourcesClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.server.respClassDescriptionManager 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)
. -
Classes in org.infinispan.util.concurrent used by org.infinispan.util.concurrentClassDescriptionManager 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. -
Classes in org.infinispan.util.concurrent used by org.infinispan.xsite.eventsClassDescriptionManager 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