Uses of Package
org.infinispan.util.concurrent

Packages that use org.infinispan.util.concurrent

Package	Description
org.infinispan.cache.impl
org.infinispan.configuration.cache	Cache configuration
org.infinispan.container.impl	Data containers which store cache entries.
org.infinispan.container.offheap
org.infinispan.executors	Implementations of different executors used for asynchronous operation.
org.infinispan.factories	Factories are internal components used to create other components based on a cache's configuration.
org.infinispan.globalstate	Global configuration state.
org.infinispan.globalstate.impl
org.infinispan.notifications.impl
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.jdbc.common.impl
org.infinispan.persistence.sifs	Soft Index AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.support
org.infinispan.search.mapper.impl
org.infinispan.search.mapper.mapping
org.infinispan.search.mapper.mapping.impl
org.infinispan.search.mapper.work.impl
org.infinispan.server.core
org.infinispan.server.core.admin
org.infinispan.server.core.backup
org.infinispan.server.core.backup.resources
org.infinispan.util.concurrent	Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.
org.infinispan.util.concurrent.locks	Lock and synchronization related classes, tools and utilities.
org.infinispan.xsite.events

Classes in org.infinispan.util.concurrent used by org.infinispan.cache.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.configuration.cache

Class	Description
IsolationLevel	Various transaction isolation levels as an enumerated class.

Classes in org.infinispan.util.concurrent used by org.infinispan.container.impl

Class	Description
DataOperationOrderer	Ordering 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.offheap

Class	Description
DataOperationOrderer	Ordering 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.executors

Class	Description
BlockingRunnable	A special Runnable that is only sent to a thread when it is ready to be executed without blocking the thread
BlockingTaskAwareExecutorService	Executor 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.factories

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
CommandAckCollector	An acknowledge collector for Triangle algorithm used in non-transactional caches for write operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.globalstate

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.globalstate.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.notifications.impl

Class	Description
AggregateCompletionStage	Aggregation of multiple CompletionStage instances where their count is not known or when a large amount of stages are required, as it uses less memory foot print per stage.

Classes in org.infinispan.util.concurrent used by org.infinispan.persistence

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.jdbc.common.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.sifs

Class	Description
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.spi

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.persistence.support

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.mapping

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.mapping.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.search.mapper.work.impl

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.server.core

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.admin

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.backup

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.server.core.backup.resources

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).

Classes in org.infinispan.util.concurrent used by org.infinispan.util.concurrent

Class	Description
AggregateCompletionStage	Aggregation of multiple CompletionStage instances where their count is not known or when a large amount of stages are required, as it uses less memory foot print per stage.
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).
BlockingManager.BlockingExecutor	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.
BlockingRunnable	A special Runnable that is only sent to a thread when it is ready to be executed without blocking the thread
BlockingTaskAwareExecutorService	Executor 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.
CommandAckCollector.MultiTargetCollector
DataOperationOrderer.Operation
IsolationLevel	Various transaction isolation levels as an enumerated class.
NonBlockingManager	Manager utility for non-blocking operations.

Classes in org.infinispan.util.concurrent used by org.infinispan.util.concurrent.locks

Class	Description
TimeoutException	Thrown when a timeout occurred.

Classes in org.infinispan.util.concurrent used by org.infinispan.xsite.events

Class	Description
BlockingManager	Manager utility for blocking operations that runs tasks on the blocking executor and returns a CompletionStage or Publisher that continues on the non-blocking executor, similar to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).