GigaSpaces XAP 7.0 API

Uses of Interface
com.gigaspaces.async.AsyncFuture

Packages that use AsyncFuture
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
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
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
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template, AsyncFutureListener<T> listener)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template, long timeout)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template, long timeout)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template, long timeout, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template, long timeout, AsyncFutureListener<T> listener)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template, long timeout, int modifiers)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template, long timeout, int modifiers)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncRead(Query<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncRead(Query<T> template, long timeout, int 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)
          Reads any matching entry from the space in an asynchronous manner.
<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)
          Reads any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template)
          Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template, AsyncFutureListener<T> listener)
          Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template, long timeout)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template, long timeout)
          Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template, long timeout, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template, long timeout, AsyncFutureListener<T> listener)
          Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template, long timeout, int modifiers)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template, long timeout, int modifiers)
          Take (remove) any matching entry from the space in an asynchronous manner.
<T> AsyncFuture<T>
DefaultGigaSpace.asyncTake(Query<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener)
           
<T> AsyncFuture<T>
GigaSpace.asyncTake(Query<T> template, long timeout, int 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)
          Take (remove) any matching entry from the space in an asynchronous manner.
<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)
          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, net.jini.core.transaction.Transaction tx)
           
 

Methods in org.openspaces.core with parameters of type AsyncFuture
<T> AsyncFuture<T>
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future, net.jini.core.transaction.Transaction tx)
           
 

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

Methods in org.openspaces.core.executor.juc that return AsyncFuture
<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
 AsyncFuture AsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener)
          Perform the async receive operation.
 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).
 AsyncFuture ExclusiveReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener)
          Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.
 


GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.