Package org.infinispan.util.concurrent

Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.

See:
Description

Interface Summary

BufferedConcurrentHashMap.EvictionListener<K,V>
BufferedConcurrentHashMap.EvictionPolicy<K,V>
FutureListener<T>	A listener that is called back when a future is done.
NotifyingFuture<T>	A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified of when the future completes.
NotifyingNotifiableFuture<Object>	An internal interface which adds the ability to inform the future of completion.

Class Summary

AggregatingNotifyingFutureImpl	For use with > 1 underlying network future
BoundedExecutors	Similar to JDK Executors except that the factory methods here allow you to specify the size of the blocking queue that backs the executor.
BufferedConcurrentHashMap<K,V>	A hash table supporting full concurrency of retrievals and adjustable expected concurrency for updates.
ConcurrentHashSet<E>	A simple Set implementation backed by a ConcurrentHashMap to deal with the fact that the JDK does not have a proper concurrent Set implementation that uses efficient lock striping.
NotifyingFutureImpl	Constructs an instance of a NotifyingFuture.
ReclosableLatch	A thread gat, that uses an AbstractQueuedSynchronizer.
SynchronizedRestarter	A class that handles restarts of components via multiple threads.
WithinThreadExecutor	An executor that works within the current thread.

Enum Summary

BufferedConcurrentHashMap.Eviction
IsolationLevel	Various transaction isolation levels as an enumerated class.

Exception Summary

TimeoutException

Thrown when a timeout occurred.

Package org.infinispan.util.concurrent Description

Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.