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)
           
 


-->

Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.