Uses of Interface
org.infinispan.util.concurrent.NotifyingFuture

Packages that use NotifyingFuture

org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.api	API package
org.infinispan.client.hotrod
org.infinispan.client.hotrod.impl
org.infinispan.client.hotrod.impl.async
org.infinispan.distexec
org.infinispan.util.concurrent	Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.

Uses of NotifyingFuture in org.infinispan

Methods in org.infinispan that return NotifyingFuture

NotifyingFuture<Void>	DecoratedCache.clearAsync()
NotifyingFuture<Void>	CacheImpl.clearAsync()
NotifyingFuture<Void>	AbstractDelegatingCache.clearAsync()
NotifyingFuture<V>	DecoratedCache.getAsync(K key)
NotifyingFuture<V>	CacheImpl.getAsync(K key)
NotifyingFuture<V>	AbstractDelegatingCache.getAsync(K key)
NotifyingFuture<Void>	DecoratedCache.putAllAsync(Map<? extends K,? extends V> data)
NotifyingFuture<Void>	CacheSupport.putAllAsync(Map<? extends K,? extends V> data)
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data)
NotifyingFuture<Void>	DecoratedCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	CacheSupport.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	DecoratedCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Void>	CacheImpl.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	DecoratedCache.putAsync(K key, V value)
NotifyingFuture<V>	CacheSupport.putAsync(K key, V value)
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value)
NotifyingFuture<V>	DecoratedCache.putAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheSupport.putAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	DecoratedCache.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheImpl.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	DecoratedCache.putIfAbsentAsync(K key, V value)
NotifyingFuture<V>	CacheSupport.putIfAbsentAsync(K key, V value)
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value)
NotifyingFuture<V>	DecoratedCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheSupport.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	DecoratedCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheImpl.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	DecoratedCache.removeAsync(Object key)
NotifyingFuture<V>	CacheImpl.removeAsync(Object key)
NotifyingFuture<V>	AbstractDelegatingCache.removeAsync(Object key)
NotifyingFuture<Boolean>	DecoratedCache.removeAsync(Object key, Object value)
NotifyingFuture<Boolean>	CacheImpl.removeAsync(Object key, Object value)
NotifyingFuture<Boolean>	AbstractDelegatingCache.removeAsync(Object key, Object value)
NotifyingFuture<V>	DecoratedCache.replaceAsync(K key, V value)
NotifyingFuture<V>	CacheSupport.replaceAsync(K key, V value)
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value)
NotifyingFuture<V>	DecoratedCache.replaceAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheSupport.replaceAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	DecoratedCache.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheImpl.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	DecoratedCache.replaceAsync(K key, V oldValue, V newValue)
NotifyingFuture<Boolean>	CacheSupport.replaceAsync(K key, V oldValue, V newValue)
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue)
NotifyingFuture<Boolean>	DecoratedCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	CacheSupport.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	DecoratedCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	CacheImpl.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)

Uses of NotifyingFuture in org.infinispan.api

Methods in org.infinispan.api that return NotifyingFuture

NotifyingFuture<Void>	BasicCache.clearAsync() Asynchronous version of Map.clear().
NotifyingFuture<V>	BasicCache.getAsync(K key) Asynchronous version of Map.get(Object) that allows user code to retrieve the value associated with a key at a later stage, hence allowing multiple parallel get requests to be sent.
NotifyingFuture<Void>	BasicCache.putAllAsync(Map<? extends K,? extends V> data) Asynchronous version of Map.putAll(Map).
NotifyingFuture<Void>	BasicCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit) Asynchronous version of BasicCache.putAll(Map, long, TimeUnit).
NotifyingFuture<Void>	BasicCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of BasicCache.putAll(Map, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	BasicCache.putAsync(K key, V value) Asynchronous version of Map.put(Object, Object).
NotifyingFuture<V>	BasicCache.putAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of BasicCache.put(Object, Object, long, TimeUnit) .
NotifyingFuture<V>	BasicCache.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of BasicCache.put(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	BasicCache.putIfAbsentAsync(K key, V value) Asynchronous version of ConcurrentMap.putIfAbsent(Object, Object).
NotifyingFuture<V>	BasicCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of BasicCache.putIfAbsent(Object, Object, long, TimeUnit) .
NotifyingFuture<V>	BasicCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of BasicCache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	BasicCache.removeAsync(Object key) Asynchronous version of Map.remove(Object).
NotifyingFuture<Boolean>	BasicCache.removeAsync(Object key, Object value) Asynchronous version of ConcurrentMap.remove(Object, Object).
NotifyingFuture<V>	BasicCache.replaceAsync(K key, V value) Asynchronous version of ConcurrentMap.replace(Object, Object).
NotifyingFuture<V>	BasicCache.replaceAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of BasicCache.replace(Object, Object, long, TimeUnit).
NotifyingFuture<V>	BasicCache.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of BasicCache.replace(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<Boolean>	BasicCache.replaceAsync(K key, V oldValue, V newValue) Asynchronous version of ConcurrentMap.replace(Object, Object, Object).
NotifyingFuture<Boolean>	BasicCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit) Asynchronous version of BasicCache.replace(Object, Object, Object, long, TimeUnit).
NotifyingFuture<Boolean>	BasicCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of BasicCache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit).

Uses of NotifyingFuture in org.infinispan.client.hotrod

Methods in org.infinispan.client.hotrod that return NotifyingFuture

NotifyingFuture<Void>	RemoteCache.putAllAsync(Map<? extends K,? extends V> data) Synthetic operation.
NotifyingFuture<Void>	RemoteCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit) Synthetic operation.
NotifyingFuture<Void>	RemoteCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Synthetic operation.
NotifyingFuture<Boolean>	RemoteCache.removeAsync(Object key, Object value) This operation is not supported.
NotifyingFuture<Boolean>	RemoteCache.removeWithVersionAsync(K key, long version)
NotifyingFuture<Boolean>	RemoteCache.replaceAsync(K key, V oldValue, V newValue) This operation is not supported.
NotifyingFuture<Boolean>	RemoteCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit) This operation is not supported.
NotifyingFuture<Boolean>	RemoteCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) This operation is not supported.
NotifyingFuture<Boolean>	RemoteCache.replaceWithVersionAsync(K key, V newValue, long version)
NotifyingFuture<Boolean>	RemoteCache.replaceWithVersionAsync(K key, V newValue, long version, int lifespanSeconds)
NotifyingFuture<Boolean>	RemoteCache.replaceWithVersionAsync(K key, V newValue, long version, int lifespanSeconds, int maxIdleSeconds)

Uses of NotifyingFuture in org.infinispan.client.hotrod.impl

Methods in org.infinispan.client.hotrod.impl that return NotifyingFuture

NotifyingFuture<Void>	RemoteCacheImpl.clearAsync()
NotifyingFuture<V>	RemoteCacheImpl.getAsync(K key)
NotifyingFuture<Void>	RemoteCacheImpl.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	RemoteCacheImpl.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	RemoteCacheImpl.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	RemoteCacheImpl.removeAsync(Object key)
NotifyingFuture<Boolean>	RemoteCacheSupport.removeAsync(Object key, Object value)
NotifyingFuture<Boolean>	RemoteCacheImpl.removeWithVersionAsync(K key, long version)
NotifyingFuture<V>	RemoteCacheImpl.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	RemoteCacheSupport.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	RemoteCacheSupport.replaceWithVersionAsync(K key, V newValue, long version)
NotifyingFuture<Boolean>	RemoteCacheSupport.replaceWithVersionAsync(K key, V newValue, long version, int lifespanSeconds)
NotifyingFuture<Boolean>	RemoteCacheImpl.replaceWithVersionAsync(K key, V newValue, long version, int lifespanSeconds, int maxIdleSeconds)

Uses of NotifyingFuture in org.infinispan.client.hotrod.impl.async

Methods in org.infinispan.client.hotrod.impl.async that return NotifyingFuture

NotifyingFuture<T>

NotifyingFutureImpl.attachListener(FutureListener<T> futureListener)

Uses of NotifyingFuture in org.infinispan.distexec

Classes in org.infinispan.distexec that implement NotifyingFuture

protected static class

DefaultExecutorService.DistributedRunnableFuture<V> DistributedRunnableFuture is essentially a Future wrap around DistributedExecuteCommand.

Fields in org.infinispan.distexec with type parameters of type NotifyingFuture

protected BlockingQueue<NotifyingFuture<V>>

DistributedExecutionCompletionService.completionQueue

Methods in org.infinispan.distexec that return NotifyingFuture

NotifyingFuture<V>	DefaultExecutorService.DistributedRunnableFuture.attachListener(FutureListener<V> listener)
NotifyingFuture<V>	DistributedExecutionCompletionService.poll()
NotifyingFuture<V>	DistributedExecutionCompletionService.poll(long timeout, TimeUnit unit)
<T> NotifyingFuture<T>	DefaultExecutorService.submit(Callable<T> task)
<T> NotifyingFuture<T>	DefaultExecutorService.submit(Runnable task, T result)
NotifyingFuture<V>	DistributedExecutionCompletionService.take()

Constructor parameters in org.infinispan.distexec with type arguments of type NotifyingFuture

DistributedExecutionCompletionService(DistributedExecutorService executor, BlockingQueue<NotifyingFuture<V>> completionQueue)
Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

DistributedExecutionCompletionService(DistributedExecutorService executor, BlockingQueue<NotifyingFuture<V>> completionQueue, DistributedExecutionCompletionService.QueueingListener listener)
This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

Uses of NotifyingFuture in org.infinispan.util.concurrent

Subinterfaces of NotifyingFuture in org.infinispan.util.concurrent

interface

NotifyingNotifiableFuture<T> An internal interface which adds the ability to inform the future of completion.

Classes in org.infinispan.util.concurrent that implement NotifyingFuture

class	AbstractInProcessNotifyingFuture<V> An abstract NotifyingFuture that has "completed"
class	AggregatingNotifyingFutureBuilder An aggregating NotifyingNotifiableFuture implementation that allows a dynamic number of futures to be attached.
class	AggregatingNotifyingFutureImpl For use with > 1 underlying network future
class	DeferredReturnFuture<V> This is a notifying and notifiable future whose return value is not known at construction time.
class	NoOpFuture<E> A future that doesn't do anything and simply returns a given return value.
class	NotifyingFutureImpl Constructs an instance of a NotifyingFuture.

Methods in org.infinispan.util.concurrent that return NotifyingFuture

NotifyingFuture<E>	NoOpFuture.attachListener(FutureListener<E> eFutureListener)
NotifyingFuture<Object>	NotifyingFutureImpl.attachListener(FutureListener<Object> objectFutureListener)
NotifyingFuture<T>	NotifyingFuture.attachListener(FutureListener<T> listener) Attaches a listener and returns the same future instance, to allow for 'building'.
NotifyingFuture<V>	DeferredReturnFuture.attachListener(FutureListener<V> objectFutureListener)
NotifyingFuture<V>	AbstractInProcessNotifyingFuture.attachListener(FutureListener<V> futureListener)