Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.cache.impl | |
org.infinispan.client.hotrod |
HotRod Client API
|
org.infinispan.client.hotrod.impl | |
org.infinispan.commons.api |
Commons API package
|
org.infinispan.commons.util.concurrent |
Provides commons interfaces and classes related to concurrency
|
org.infinispan.distexec |
Distribute Executor APIs
|
org.infinispan.security.impl | |
org.infinispan.util.concurrent |
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
|
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<V> |
AdvancedCache.putAsync(K key,
V value,
Metadata metadata)
Asynchronous version of
AdvancedCache.put(Object, Object, Metadata) which stores
metadata alongside the value. |
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<Void> |
DecoratedCache.clearAsync() |
NotifyingFuture<Void> |
CacheImpl.clearAsync() |
NotifyingFuture<Void> |
AbstractDelegatingCache.clearAsync() |
NotifyingFuture<Void> |
SimpleCacheImpl.clearAsync() |
NotifyingFuture<V> |
DecoratedCache.getAsync(K key) |
NotifyingFuture<V> |
CacheImpl.getAsync(K key) |
NotifyingFuture<V> |
AbstractDelegatingCache.getAsync(K key) |
NotifyingFuture<V> |
SimpleCacheImpl.getAsync(K key) |
NotifyingFuture<Void> |
DecoratedCache.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
CacheImpl.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
AbstractDelegatingCache.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
SimpleCacheImpl.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
CacheSupport.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
DecoratedCache.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit unit) |
NotifyingFuture<Void> |
CacheImpl.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> |
SimpleCacheImpl.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> |
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<Void> |
SimpleCacheImpl.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> |
CacheImpl.putAsync(K key,
V value) |
NotifyingFuture<V> |
AbstractDelegatingCache.putAsync(K key,
V value) |
NotifyingFuture<V> |
SimpleCacheImpl.putAsync(K key,
V value) |
NotifyingFuture<V> |
CacheSupport.putAsync(K key,
V value) |
NotifyingFuture<V> |
DecoratedCache.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
AbstractDelegatingCache.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SimpleCacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheSupport.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> |
SimpleCacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
DecoratedCache.putAsync(K key,
V value,
Metadata metadata) |
NotifyingFuture<V> |
CacheImpl.putAsync(K key,
V value,
Metadata metadata) |
NotifyingFuture<V> |
AbstractDelegatingAdvancedCache.putAsync(K key,
V value,
Metadata metadata) |
NotifyingFuture<V> |
SimpleCacheImpl.putAsync(K key,
V value,
Metadata metadata) |
NotifyingFuture<V> |
DecoratedCache.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
CacheImpl.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
AbstractDelegatingCache.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
SimpleCacheImpl.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
CacheSupport.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
DecoratedCache.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheImpl.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
AbstractDelegatingCache.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SimpleCacheImpl.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheSupport.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> |
SimpleCacheImpl.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<V> |
SimpleCacheImpl.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<Boolean> |
SimpleCacheImpl.removeAsync(Object key,
Object value) |
NotifyingFuture<V> |
DecoratedCache.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
CacheImpl.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
AbstractDelegatingCache.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
SimpleCacheImpl.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
CacheSupport.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
DecoratedCache.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheImpl.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
AbstractDelegatingCache.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SimpleCacheImpl.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
CacheSupport.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<V> |
SimpleCacheImpl.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> |
CacheImpl.replaceAsync(K key,
V oldValue,
V newValue) |
NotifyingFuture<Boolean> |
AbstractDelegatingCache.replaceAsync(K key,
V oldValue,
V newValue) |
NotifyingFuture<Boolean> |
SimpleCacheImpl.replaceAsync(K key,
V oldValue,
V newValue) |
NotifyingFuture<Boolean> |
CacheSupport.replaceAsync(K key,
V oldValue,
V newValue) |
NotifyingFuture<Boolean> |
DecoratedCache.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit unit) |
NotifyingFuture<Boolean> |
CacheImpl.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> |
SimpleCacheImpl.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> |
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) |
NotifyingFuture<Boolean> |
SimpleCacheImpl.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
Modifier and Type | Method and Description |
---|---|
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.removeWithVersionAsync(K key,
long version) |
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) |
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<Void> |
RemoteCacheImpl.clearAsync() |
NotifyingFuture<V> |
RemoteCacheImpl.getAsync(K key) |
NotifyingFuture<Void> |
RemoteCacheSupport.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
RemoteCacheSupport.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit unit) |
NotifyingFuture<Void> |
RemoteCacheImpl.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
RemoteCacheSupport.putAsync(K key,
V value) |
NotifyingFuture<V> |
RemoteCacheSupport.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
RemoteCacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
RemoteCacheSupport.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
RemoteCacheSupport.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit) |
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> |
RemoteCacheSupport.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
RemoteCacheSupport.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
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) |
NotifyingFuture<Boolean> |
RemoteCacheSupport.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit unit) |
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) |
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<Void> |
AsyncCache.clearAsync()
Asynchronous version of
#clear() . |
NotifyingFuture<V> |
AsyncCache.getAsync(K key)
Asynchronous version of
#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> |
AsyncCache.putAllAsync(Map<? extends K,? extends V> data)
Asynchronous version of
#putAll(Map) . |
NotifyingFuture<Void> |
AsyncCache.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit unit)
Asynchronous version of
#putAll(Map, long, TimeUnit) . |
NotifyingFuture<Void> |
AsyncCache.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
#putAll(Map, long, TimeUnit, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.putAsync(K key,
V value)
Asynchronous version of
#put(Object, Object) . |
NotifyingFuture<V> |
AsyncCache.putAsync(K key,
V value,
long lifespan,
TimeUnit unit)
Asynchronous version of
#put(Object, Object, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.putAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
#put(Object, Object, long, TimeUnit, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.putIfAbsentAsync(K key,
V value)
Asynchronous version of
#putIfAbsent(Object, Object) . |
NotifyingFuture<V> |
AsyncCache.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit)
Asynchronous version of
#putIfAbsent(Object, Object, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
#putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.removeAsync(Object key)
Asynchronous version of
#remove(Object) . |
NotifyingFuture<Boolean> |
AsyncCache.removeAsync(Object key,
Object value)
Asynchronous version of
#remove(Object, Object) . |
NotifyingFuture<V> |
AsyncCache.replaceAsync(K key,
V value)
Asynchronous version of
#replace(Object, Object) . |
NotifyingFuture<V> |
AsyncCache.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit)
Asynchronous version of
#replace(Object, Object, long, TimeUnit) . |
NotifyingFuture<V> |
AsyncCache.replaceAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
#replace(Object, Object, long, TimeUnit, long, TimeUnit) . |
NotifyingFuture<Boolean> |
AsyncCache.replaceAsync(K key,
V oldValue,
V newValue)
Asynchronous version of
#replace(Object, Object, Object) . |
NotifyingFuture<Boolean> |
AsyncCache.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit unit)
Asynchronous version of
#replace(Object, Object, Object, long, TimeUnit) . |
NotifyingFuture<Boolean> |
AsyncCache.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit)
Asynchronous version of
#replace(Object, Object, Object, long, TimeUnit, long, TimeUnit) . |
Modifier and Type | Interface and Description |
---|---|
interface |
NotifyingNotifiableFuture<T>
An internal interface which adds the ability to inform the future of completion.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractInProcessNotifyingFuture<V>
An abstract NotifyingFuture that has "completed"
|
class |
BaseNotifyingFuture<T> |
class |
CompositeNotifyingFuture<T>
CompositeNotifyingFuture aggregates several NotifyingFuture and completes when all of them complete.
|
class |
NoOpFuture<E>
A future that doesn't do anything and simply returns a given return value.
|
class |
NotifyingFutureImpl<T>
Constructs an instance of a
NotifyingFuture . |
Modifier and Type | Method and Description |
---|---|
static <T> NotifyingFuture<Void> |
Futures.andThen(NotifyingFuture<T> future,
Runnable after) |
static <T> NotifyingFuture<Void> |
Futures.andThen(NotifyingFuture<T> future,
Runnable after,
ExecutorService executorService)
Executes a task asynchronously after a future completion
|
NotifyingFuture<E> |
NoOpFuture.attachListener(FutureListener<E> eFutureListener) |
NotifyingFuture<T> |
NotifyingFuture.attachListener(FutureListener<T> listener)
Attaches a listener and returns the same future instance, to allow for 'building'.
|
NotifyingFuture<T> |
BaseNotifyingFuture.attachListener(FutureListener<T> objectFutureListener) |
NotifyingFuture<V> |
AbstractInProcessNotifyingFuture.attachListener(FutureListener<V> futureListener) |
static <T> NotifyingFuture<List<T>> |
Futures.combine(List<NotifyingFuture<T>> futures)
Returns a new
NotifyingFuture that will be completed when all of
the given futures completes. |
Modifier and Type | Method and Description |
---|---|
static <T> NotifyingFuture<Void> |
Futures.andThen(NotifyingFuture<T> future,
Runnable after) |
static <T> NotifyingFuture<Void> |
Futures.andThen(NotifyingFuture<T> future,
Runnable after,
ExecutorService executorService)
Executes a task asynchronously after a future completion
|
Modifier and Type | Method and Description |
---|---|
static <T> NotifyingFuture<List<T>> |
Futures.combine(List<NotifyingFuture<T>> futures)
Returns a new
NotifyingFuture that will be completed when all of
the given futures completes. |
Constructor and Description |
---|
CompositeNotifyingFuture(List<NotifyingFuture<T>> futures) |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<NotifyingFuture<V>> |
DistributedExecutionCompletionService.completionQueue |
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<V> |
DistributedExecutionCompletionService.poll() |
NotifyingFuture<V> |
DistributedExecutionCompletionService.poll(long timeout,
TimeUnit unit) |
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Address target,
Callable<T> task) |
<T> NotifyingFuture<T> |
DistributedExecutorService.submit(Address target,
Callable<T> task)
Submits the given Callable task for execution on the specified target Infinispan node.
|
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Address target,
DistributedTask<T> task) |
<T> NotifyingFuture<T> |
DistributedExecutorService.submit(Address target,
DistributedTask<T> task)
Submits the given DistributedTask for execution on the specified target Infinispan node.
|
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Callable<T> task) |
<T,K> NotifyingFuture<T> |
DefaultExecutorService.submit(Callable<T> task,
K... input) |
<T,K> NotifyingFuture<T> |
DistributedExecutorService.submit(Callable<T> task,
K... input)
Submits the given Callable task for execution on a single Infinispan node.
|
<T,K> NotifyingFuture<T> |
DefaultExecutorService.submit(DistributedTask<T> task,
K... input) |
<T,K> NotifyingFuture<T> |
DistributedExecutorService.submit(DistributedTask<T> task,
K... input)
Submits the given DistributedTask for execution on a single Infinispan node.
|
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Runnable task,
T result) |
NotifyingFuture<V> |
DistributedExecutionCompletionService.take() |
Constructor and Description |
---|
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.
|
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<Void> |
SecureCacheImpl.clearAsync() |
NotifyingFuture<V> |
SecureCacheImpl.getAsync(K key) |
NotifyingFuture<Void> |
SecureCacheImpl.putAllAsync(Map<? extends K,? extends V> data) |
NotifyingFuture<Void> |
SecureCacheImpl.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit unit) |
NotifyingFuture<Void> |
SecureCacheImpl.putAllAsync(Map<? extends K,? extends V> data,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
SecureCacheImpl.putAsync(K key,
V value) |
NotifyingFuture<V> |
SecureCacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SecureCacheImpl.putAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
SecureCacheImpl.putAsync(K key,
V value,
Metadata metadata) |
NotifyingFuture<V> |
SecureCacheImpl.putIfAbsentAsync(K key,
V value) |
NotifyingFuture<V> |
SecureCacheImpl.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SecureCacheImpl.putIfAbsentAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<V> |
SecureCacheImpl.removeAsync(Object key) |
NotifyingFuture<Boolean> |
SecureCacheImpl.removeAsync(Object key,
Object value) |
NotifyingFuture<V> |
SecureCacheImpl.replaceAsync(K key,
V value) |
NotifyingFuture<V> |
SecureCacheImpl.replaceAsync(K key,
V value,
long lifespan,
TimeUnit unit) |
NotifyingFuture<V> |
SecureCacheImpl.replaceAsync(K key,
V value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
NotifyingFuture<Boolean> |
SecureCacheImpl.replaceAsync(K key,
V oldValue,
V newValue) |
NotifyingFuture<Boolean> |
SecureCacheImpl.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit unit) |
NotifyingFuture<Boolean> |
SecureCacheImpl.replaceAsync(K key,
V oldValue,
V newValue,
long lifespan,
TimeUnit lifespanUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<T> |
CompletableFutures.toCompletableFuture(NotifyingFuture<T> source) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.