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.client.hotrod
org.infinispan.client.hotrod.impl
org.infinispan.client.hotrod.impl.async
org.infinispan.distexec
org.infinispan.tree	This package contains the TreeCache.
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>	CacheImpl.clearAsync()
NotifyingFuture<Void>	Cache.clearAsync() Asynchronous version of Map.clear().
NotifyingFuture<Void>	AbstractDelegatingCache.clearAsync()
NotifyingFuture<V>	CacheImpl.getAsync(K key)
NotifyingFuture<V>	Cache.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<V>	AbstractDelegatingCache.getAsync(K key)
NotifyingFuture<Void>	CacheSupport.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>	CacheSupport.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>	CacheImpl.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>	CacheSupport.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>	CacheSupport.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>	CacheImpl.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>	CacheSupport.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>	CacheSupport.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>	CacheImpl.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>	CacheImpl.removeAsync(Object key)
NotifyingFuture<V>	Cache.removeAsync(Object key) Asynchronous version of Map.remove(Object).
NotifyingFuture<V>	AbstractDelegatingCache.removeAsync(Object key)
NotifyingFuture<Boolean>	CacheImpl.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>	CacheSupport.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>	CacheSupport.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>	CacheImpl.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>	CacheSupport.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>	CacheSupport.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>	CacheImpl.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.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 futureListener)

Uses of NotifyingFuture in org.infinispan.distexec

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

Methods in org.infinispan.tree that return NotifyingFuture

NotifyingFuture<Void>	CacheAdapter.clearAsync()
NotifyingFuture	CacheAdapter.getAsync(Object key)
NotifyingFuture<Void>	CacheAdapter.putAllAsync(Map data)
NotifyingFuture<Void>	CacheAdapter.putAllAsync(Map data, long lifespan, TimeUnit unit)
NotifyingFuture<Void>	CacheAdapter.putAllAsync(Map data, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture	CacheAdapter.putAsync(Object key, Object value)
NotifyingFuture	CacheAdapter.putAsync(Object key, Object value, long lifespan, TimeUnit unit)
NotifyingFuture	CacheAdapter.putAsync(Object key, Object value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture	CacheAdapter.putIfAbsentAsync(Object key, Object value)
NotifyingFuture	CacheAdapter.putIfAbsentAsync(Object key, Object value, long lifespan, TimeUnit unit)
NotifyingFuture	CacheAdapter.putIfAbsentAsync(Object key, Object value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture	CacheAdapter.removeAsync(Object key)
NotifyingFuture<Boolean>	CacheAdapter.removeAsync(Object key, Object value)
NotifyingFuture	CacheAdapter.replaceAsync(Object key, Object value)
NotifyingFuture	CacheAdapter.replaceAsync(Object key, Object value, long lifespan, TimeUnit unit)
NotifyingFuture	CacheAdapter.replaceAsync(Object key, Object value, long lifespan, TimeUnit lifespanUnit, long maxIdle, TimeUnit maxIdleUnit)
NotifyingFuture<Boolean>	CacheAdapter.replaceAsync(Object key, Object oldValue, Object newValue)
NotifyingFuture<Boolean>	CacheAdapter.replaceAsync(Object key, Object oldValue, Object newValue, long lifespan, TimeUnit unit)
NotifyingFuture<Boolean>	CacheAdapter.replaceAsync(Object key, Object oldValue, Object 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<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	AggregatingNotifyingFutureImpl For use with > 1 underlying network future
class	DeferredReturnFuture This is a notifying and notifiable future whose return value is not known at construction time.
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<Object>	DeferredReturnFuture.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>	AbstractInProcessNotifyingFuture.attachListener(FutureListener<V> futureListener)