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

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<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.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 AbstractInProcessNotifyingFuture<V>
          An abstract NotifyingFuture that has "completed"
 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'.
 NotifyingFuture<V> AbstractInProcessNotifyingFuture.attachListener(FutureListener<V> futureListener)
           
 


Google Analytics

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