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.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>	CacheDelegate.clearAsync()
NotifyingFuture<Void>	Cache.clearAsync() Asynchronous version of Map.clear().
NotifyingFuture<Void>	AbstractDelegatingCache.clearAsync()
NotifyingFuture<Void>	CacheDelegate.putAllAsync(Map<? extends K,? extends V> data)
NotifyingFuture<Void>	Cache.putAllAsync(Map<? extends K,? extends V> data) Asynchronous version of Map.putAll(Map).
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data)
NotifyingFuture<Void>	CacheDelegate.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	Cache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit) Asynchronous version of Cache.putAll(Map, long, TimeUnit).
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	CacheDelegate.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Void>	Cache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of Cache.putAll(Map, long, TimeUnit, long, TimeUnit).
NotifyingFuture<Void>	AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheDelegate.putAsync(K key, V value)
NotifyingFuture<V>	Cache.putAsync(K key, V value) Asynchronous version of Map.put(Object, Object).
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value)
NotifyingFuture<V>	CacheDelegate.putAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	Cache.putAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of Cache.put(Object, Object, long, TimeUnit) .
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheDelegate.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	Cache.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of Cache.put(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	AbstractDelegatingCache.putAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheDelegate.putIfAbsentAsync(K key, V value)
NotifyingFuture<V>	Cache.putIfAbsentAsync(K key, V value) Asynchronous version of ConcurrentMap.putIfAbsent(Object, Object).
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value)
NotifyingFuture<V>	CacheDelegate.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	Cache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of Cache.putIfAbsent(Object, Object, long, TimeUnit) .
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheDelegate.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	Cache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of Cache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	AbstractDelegatingCache.putIfAbsentAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	CacheDelegate.removeAsync(Object key)
NotifyingFuture<V>	Cache.removeAsync(Object key) Asynchronous version of Map.remove(Object).
NotifyingFuture<V>	AbstractDelegatingCache.removeAsync(Object key)
NotifyingFuture<Boolean>	CacheDelegate.removeAsync(Object key, Object value)
NotifyingFuture<Boolean>	Cache.removeAsync(Object key, Object value) Asynchronous version of ConcurrentMap.remove(Object, Object).
NotifyingFuture<Boolean>	AbstractDelegatingCache.removeAsync(Object key, Object value)
NotifyingFuture<V>	CacheDelegate.replaceAsync(K key, V value)
NotifyingFuture<V>	Cache.replaceAsync(K key, V value) Asynchronous version of ConcurrentMap.replace(Object, Object).
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value)
NotifyingFuture<V>	CacheDelegate.replaceAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	Cache.replaceAsync(K key, V value, long lifespan, TimeUnit unit) Asynchronous version of Cache.replace(Object, Object, long, TimeUnit).
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value, long lifespan, TimeUnit unit)
NotifyingFuture<V>	CacheDelegate.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<V>	Cache.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of Cache.replace(Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<V>	AbstractDelegatingCache.replaceAsync(K key, V value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	CacheDelegate.replaceAsync(K key, V oldValue, V newValue)
NotifyingFuture<Boolean>	Cache.replaceAsync(K key, V oldValue, V newValue) Asynchronous version of ConcurrentMap.replace(Object, Object, Object).
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue)
NotifyingFuture<Boolean>	CacheDelegate.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	Cache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit) Asynchronous version of Cache.replace(Object, Object, Object, long, TimeUnit).
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	CacheDelegate.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	Cache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit) Asynchronous version of Cache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit).
NotifyingFuture<Boolean>	AbstractDelegatingCache.replaceAsync(K key, V oldValue, V newValue, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)

Uses of NotifyingFuture in org.infinispan.util.concurrent

Subinterfaces of NotifyingFuture in org.infinispan.util.concurrent

interface

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

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

class	AggregatingNotifyingFutureImpl For use with > 1 underlying network future
class	NotifyingFutureImpl Constructs an instance of a NotifyingFuture.

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

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'.