Uses of Interface
com.gigaspaces.async.AsyncFuture
Packages that use AsyncFuture
Package
Description
Provides GigaSpaces asynchronous operations related interfaces.
Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and
the ability to create it.
-
Uses of AsyncFuture in com.gigaspaces.async
Classes in com.gigaspaces.async that implement AsyncFutureModifier and TypeClassDescriptionclassclassCreated by Barak Bar Orion 19/08/14.Methods in com.gigaspaces.async that return AsyncFutureModifier and TypeMethodDescriptionstatic <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 AsyncFutureModifier and TypeMethodDescriptionstatic <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 com.gigaspaces.async.internal
Classes in com.gigaspaces.async.internal that implement AsyncFutureModifier and TypeClassDescriptionclassclassCompoundFuture<T,R> a future implementation used to aggregate results from multiple Futures.Constructors in com.gigaspaces.async.internal with parameters of type AsyncFutureModifierConstructorDescriptionCompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T, R> reducer) CompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T, R> reducer, AsyncResultFilter<T> moderator) -
Uses of AsyncFuture in com.gigaspaces.internal.client.cache.localcache.actions
Classes in com.gigaspaces.internal.client.cache.localcache.actions that implement AsyncFutureModifier and TypeClassDescriptionclassBase class for dcache async futures, it registers with a custom listener per implementation and delegates the result to the user supplied listener when the operation is considered done (Up to the custom listener)Methods in com.gigaspaces.internal.client.cache.localcache.actions that return AsyncFutureModifier and TypeMethodDescriptionLocalCacheImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalCacheContainer spaceProxy, AddTypeIndexesRequestInfo requestInfo) AsyncFuture<?>LocalCacheImplReadTakeAction.asyncRead(LocalCacheContainer spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) AsyncFuture<?>LocalCacheImplReadTakeAction.asyncTake(LocalCacheContainer spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) LocalCacheImplAdminAction.execute(LocalCacheContainer spaceProxy, SpaceTask task, Object routing, Transaction txn, AsyncFutureListener listener, Map<String, byte[]> classes) -
Uses of AsyncFuture in com.gigaspaces.internal.client.cache.localview.actions
Methods in com.gigaspaces.internal.client.cache.localview.actions that return AsyncFutureModifier and TypeMethodDescriptionLocalViewImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalViewContainer spaceProxy, AddTypeIndexesRequestInfo requestInfo) AsyncFuture<?>LocalViewImplReadTakeAction.asyncRead(LocalViewContainer spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) AsyncFuture<?>LocalViewImplReadTakeAction.asyncTake(LocalViewContainer spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) LocalViewImplAdminAction.execute(LocalViewContainer spaceProxy, SpaceTask task, Object routing, Transaction txn, AsyncFutureListener listener, Map<String, byte[]> classes) -
Uses of AsyncFuture in com.gigaspaces.internal.client.spaceproxy
Methods in com.gigaspaces.internal.client.spaceproxy that return AsyncFutureModifier and TypeMethodDescriptionAbstractSpaceProxy.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) ISpaceProxy.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) AsyncFuture<?>AbstractSpaceProxy.asyncRead(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener listener) ISpaceProxy.asyncRead(Object template, Transaction transaction, long timeout, int modifiers, AsyncFutureListener listener) Internal methods only.AsyncFuture<?>AbstractSpaceProxy.asyncTake(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener listener) ISpaceProxy.asyncTake(Object template, Transaction transaction, long timeout, int modifiers, AsyncFutureListener listener) Internal methods only.AbstractSpaceProxy.execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener) AbstractSpaceProxy.execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener, Map<String, byte[]> classes) ISpaceProxy.execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener) Executes a task on a single space.ISpaceProxy.execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener, Map<String, byte[]> classes) Executes a task on a single space. -
Uses of AsyncFuture in com.gigaspaces.internal.client.spaceproxy.actions
Methods in com.gigaspaces.internal.client.spaceproxy.actions that return AsyncFutureModifier and TypeMethodDescriptionAbstractSpaceProxyActionManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) AsyncFuture<?>AbstractSpaceProxyActionManager.asyncRead(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener<?> listener) abstract AsyncFuture<?>ReadTakeProxyAction.asyncRead(TSpaceProxy spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) AsyncFuture<?>SpaceProxyImplReadTakeAction.asyncRead(SpaceProxyImpl spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) AsyncFuture<?>AbstractSpaceProxyActionManager.asyncTake(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener<?> listener) abstract AsyncFuture<?>ReadTakeProxyAction.asyncTake(TSpaceProxy spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) AsyncFuture<?>SpaceProxyImplReadTakeAction.asyncTake(SpaceProxyImpl spaceProxy, ReadTakeAsyncProxyActionInfo actionInfo) abstract AsyncFutureAdminProxyAction.execute(TSpaceProxy spaceProxy, SpaceTask task, Object routing, Transaction txn, AsyncFutureListener listener, Map<String, byte[]> classes) SpaceProxyImplAdminAction.execute(SpaceProxyImpl spaceProxy, SpaceTask task, Object routing, Transaction txn, AsyncFutureListener listener, Map<String, byte[]> classes) AbstractSpaceProxyActionManager.executeTask(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener, Map<String, byte[]> classes) -
Uses of AsyncFuture in com.gigaspaces.internal.client.spaceproxy.executors
Methods in com.gigaspaces.internal.client.spaceproxy.executors that return AsyncFutureModifier and TypeMethodDescriptionSpaceProxyImplTypeDescriptorActionsExecutor.asyncAddIndexes(SpaceProxyImpl spaceProxy, AddTypeIndexesRequestInfo requestInfo) abstract AsyncFuture<AddTypeIndexesResult>TypeDescriptorActionsProxyExecutor.asyncAddIndexes(TSpaceProxy spaceProxy, AddTypeIndexesRequestInfo requestInfo) -
Uses of AsyncFuture in com.gigaspaces.internal.cluster.node.impl.router
Methods in com.gigaspaces.internal.cluster.node.impl.router that return AsyncFutureModifier and TypeMethodDescription<TR> AsyncFuture<TR>AbstractProxyBasedReplicationMonitoredConnection.dispatchAsync(AbstractReplicationPacket<TR> packet) <T> AsyncFuture<T>IReplicationConnection.dispatchAsync(AbstractReplicationPacket<T> packet) <T> AsyncFuture<T>IAsyncContextProvider.getFutureContext(T syncResult, Object proxy) <T> AsyncFuture<T>LRMIAsyncContextProvider.getFutureContext(T syncResult, Object proxy) -
Uses of AsyncFuture in com.gigaspaces.internal.cluster.node.impl.router.spacefinder
Methods in com.gigaspaces.internal.cluster.node.impl.router.spacefinder that return AsyncFutureModifier and TypeMethodDescription<T> AsyncFuture<T>ConnectionReference.dispatchAsync(AbstractReplicationPacket<T> packet) -
Uses of AsyncFuture in com.gigaspaces.internal.remoting
Classes in com.gigaspaces.internal.remoting that implement AsyncFutureModifier and TypeClassDescriptionclass -
Uses of AsyncFuture in com.gigaspaces.internal.remoting.routing.partitioned
Classes in com.gigaspaces.internal.remoting.routing.partitioned that implement AsyncFutureModifier and TypeClassDescriptionclassclass -
Uses of AsyncFuture in com.gigaspaces.lrmi.nio.async
Subinterfaces of AsyncFuture in com.gigaspaces.lrmi.nio.asyncModifier and TypeInterfaceDescriptioninterfaceIFuture<T>An internal interface extending theAsyncFuture.Classes in com.gigaspaces.lrmi.nio.async that implement AsyncFutureModifier and TypeClassDescriptionclassLRMIFuture<T>A future implementation used to hold delayed result coming from one target. -
Uses of AsyncFuture in org.openspaces.core
Methods in org.openspaces.core that return AsyncFutureModifier and TypeMethodDescriptionDefaultGigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index) DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener) GigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index) Adds the specified index to the specified type.GigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified index to the specified type.DefaultGigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) GigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified indexes to the specified type.DefaultGigaSpace.asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest) GigaSpace.asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest) Loads data from aSpaceDataSourceon demand The Space data source is created withSpaceDataSourceFactoryLoaded data can be adapted using theSpaceTypeSchemaAdapter<T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(ISpaceQuery<T> template, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template, long timeout) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template, long timeout, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncRead(T template, AsyncFutureListener<T> listener) <T> AsyncFuture<T>GigaSpace.asyncRead(ISpaceQuery<T> template) Reads any matching entry from the space in an asynchronous manner.<T> AsyncFuture<T>GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout) Reads any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, ReadModifiers modifiers) Reads any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncRead(ISpaceQuery<T> template, AsyncFutureListener<T> listener) Reads any matching entry from the space in an asynchronous manner.<T> AsyncFuture<T>GigaSpace.asyncRead(T template) Reads any matching entry from the space in an asynchronous manner.<T> AsyncFuture<T>GigaSpace.asyncRead(T template, long timeout) Reads any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncRead(T template, long timeout, ReadModifiers modifiers) Reads any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncRead(T template, 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>DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(ISpaceQuery<T> template, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template, long timeout) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template, long timeout, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers, AsyncFutureListener<T> listener) <T> AsyncFuture<T>DefaultGigaSpace.asyncTake(T template, AsyncFutureListener<T> listener) <T> AsyncFuture<T>GigaSpace.asyncTake(ISpaceQuery<T> template) Take (remove) any matching entry from the space in an asynchronous manner.<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>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>GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, TakeModifiers modifiers) Take (remove) any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncTake(ISpaceQuery<T> template, AsyncFutureListener<T> listener) Take (remove) any matching entry from the space in an asynchronous manner.<T> AsyncFuture<T>GigaSpace.asyncTake(T template) Take (remove) any matching entry from the space in an asynchronous manner.<T> AsyncFuture<T>GigaSpace.asyncTake(T template, long timeout) Take (remove) any matching entry from the space in an asynchronous manner.<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>GigaSpace.asyncTake(T template, long timeout, TakeModifiers modifiers) Take (remove) any matching entry from the space in an asynchronous manner.<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> AsyncFuture<T>GigaSpace.asyncTake(T template, 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) <T extends Serializable,R>
AsyncFuture<R>DefaultGigaSpace.execute(DistributedTask<T, R> task) <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>
AsyncFuture<T><T extends Serializable>
AsyncFuture<T>DefaultGigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener) <T extends Serializable>
AsyncFuture<T><T extends Serializable>
AsyncFuture<T>DefaultGigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener) 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>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>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>Executes a task on a specific space node.<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>Executes a task on a specific space node.<T extends Serializable>
AsyncFuture<T>GigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener) Executes a task on a specific space node.DefaultGigaSpace.executeDurable(UUID uuid) GigaSpace.executeDurable(UUID uuid) DefaultGigaSpace.unregisterDurableTask(UUID id) GigaSpace.unregisterDurableTask(UUID id) <T> AsyncFuture<T>DefaultGigaSpace.wrapFuture(AsyncFuture<T> future, Transaction tx) Methods in org.openspaces.core with parameters of type AsyncFutureModifier and TypeMethodDescription<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 -
Uses of AsyncFuture in org.openspaces.core.internal
Methods in org.openspaces.core.internal that return AsyncFutureModifier and TypeMethodDescription<T> AsyncFuture<T>InternalGigaSpace.wrapFuture(AsyncFuture<T> future, Transaction tx) Methods in org.openspaces.core.internal with parameters of type AsyncFutureModifier and TypeMethodDescription<T> AsyncFuture<T>InternalGigaSpace.wrapFuture(AsyncFuture<T> future, Transaction tx) -
Uses of AsyncFuture in org.openspaces.core.transaction.internal
Classes in org.openspaces.core.transaction.internal that implement AsyncFutureConstructors in org.openspaces.core.transaction.internal with parameters of type AsyncFutureModifierConstructorDescriptionInternalAsyncFuture(AsyncFuture<T> future, GigaSpace gigaSpace) InternalAsyncFuture(AsyncFuture<T> future, GigaSpace gigaSpace, Transaction tx) -
Uses of AsyncFuture in org.openspaces.events.asyncpolling.receive
Methods in org.openspaces.events.asyncpolling.receive that return AsyncFutureModifier and TypeMethodDescriptionAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Perform the async receive operation.ExclusiveReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usignGigaSpace.asyncRead(Object)under exclusive read lock.SingleReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usignGigaSpace.asyncRead(Object).SingleTakeAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usignGigaSpace.asyncTake(Object).