Uses of Interface
com.gigaspaces.async.AsyncFuture

Packages that use AsyncFuture

Package	Description
com.gigaspaces.async	Provides GigaSpaces asynchronous operations related interfaces.
org.openspaces.core	Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and the ability to create it.
org.openspaces.core.executor.juc
org.openspaces.events.asyncpolling.receive

Uses of AsyncFuture in com.gigaspaces.async

Methods in com.gigaspaces.async that return AsyncFuture

Modifier and Type	Method and Description
static <T,R> AsyncFuture<R>	FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer)
static <T,R> AsyncFuture<R>	FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Methods in com.gigaspaces.async with parameters of type AsyncFuture

Modifier and Type	Method and Description
static <T,R> AsyncFuture<R>	FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer)
static <T,R> AsyncFuture<R>	FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Uses of AsyncFuture in org.openspaces.core

Methods in org.openspaces.core that return AsyncFuture

Modifier and Type	Method and Description
AsyncFuture<AddTypeIndexesResult>	DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index)
AsyncFuture<AddTypeIndexesResult>	GigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index) Adds the specified index to the specified type.
AsyncFuture<AddTypeIndexesResult>	DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener)
AsyncFuture<AddTypeIndexesResult>	GigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified index to the specified type.
AsyncFuture<AddTypeIndexesResult>	DefaultGigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener)
AsyncFuture<AddTypeIndexesResult>	GigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified indexes to the specified type.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, int modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, int modifiers) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(ISpaceQuery, long, ReadModifiers) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(ISpaceQuery, long, ReadModifiers, AsyncFutureListener) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout, int modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, int modifiers) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(Object, long, ReadModifiers) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(Object, long, ReadModifiers, AsyncFutureListener) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, int modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, int modifiers) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(ISpaceQuery, long, TakeModifiers) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(ISpaceQuery, long, TakeModifiers, AsyncFutureListener) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout, int modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, int modifiers) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(Object, long, TakeModifiers) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(Object, long, TakeModifiers, AsyncFutureListener) instead.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers) Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>	DefaultGigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.distExecute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
AsyncFuture<R>	ExecutorBuilder.execute() Executes all the given tasks (asynchronously) based on their execution mode and returns a future allowing to retrieve the reduced operation of all the tasks.
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task)
<T extends Serializable,R> AsyncFuture<R>	GigaSpace.execute(DistributedTask<T,R> task) Executes the task on all the primary space nodes within the cluster (broadcast).
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task, Object... routings)
<T extends Serializable,R> AsyncFuture<R>	GigaSpace.execute(DistributedTask<T,R> task, Object... routing) Executes a task on all the nodes that correspond to the list of routing values.
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task) Executes a task on a specific space node.
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener) Executes a task on a specific space node.
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task, Object routing)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task, Object routing) Executes a task on a specific space node.
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener) Executes a task on a specific space node.
<T> AsyncFuture<T>	DefaultGigaSpace.wrapFuture(AsyncFuture<T> future, Transaction tx)

Methods in org.openspaces.core with parameters of type AsyncFuture

Modifier and Type	Method and Description
<T> AsyncFuture<T>	DefaultGigaSpace.wrapFuture(AsyncFuture<T> future, Transaction tx)

Uses of AsyncFuture in org.openspaces.core.executor.juc

Methods in org.openspaces.core.executor.juc that return AsyncFuture

Modifier and Type	Method and Description
<T> AsyncFuture<T>	DefaultTaskExecutorService.submit(Callable<T> task)
AsyncFuture<?>	DefaultTaskExecutorService.submit(Runnable task)
<T> AsyncFuture<T>	DefaultTaskExecutorService.submit(Runnable task, T result)

Uses of AsyncFuture in org.openspaces.events.asyncpolling.receive

Methods in org.openspaces.events.asyncpolling.receive that return AsyncFuture

Modifier and Type	Method and Description
AsyncFuture	AsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Perform the async receive operation.
AsyncFuture	ExclusiveReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.
AsyncFuture	SingleReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncRead(Object).
AsyncFuture	SingleTakeAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncTake(Object).