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.support | |
org.openspaces.events.asyncpolling.receive |
Modifier and Type | Method and Description |
---|---|
void |
AsyncFuture.setListener(AsyncFutureListener<T> listener) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFutureListener<T> |
DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
ExecutorBuilder<T,R> |
ExecutorBuilder.add(Task<T> task,
AsyncFutureListener<T> listener)
Adds a task to be executed similarly to
GigaSpace.execute(org.openspaces.core.executor.Task) . |
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> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(ISpaceQuery<T> query,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(T template,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(T template,
ChangeSet changeSet,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(T template,
ChangeSet changeSet,
ChangeModifiers modifiers,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<T> Future<ChangeResult<T>> |
DefaultGigaSpace.asyncChange(T template,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
GigaSpace.asyncChange(T template,
ChangeSet changeSet,
long timeout,
AsyncFutureListener<ChangeResult<T>> listener)
Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
|
<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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
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> |
DefaultGigaSpace.distExecute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<T extends Serializable,R> |
DefaultGigaSpace.execute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task,
AsyncFutureListener<T> listener) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T extends Serializable> |
DefaultGigaSpace.execute(Task<T> task,
Object routing,
AsyncFutureListener<T> listener) |
<T extends Serializable> |
GigaSpace.execute(Task<T> task,
Object routing,
AsyncFutureListener<T> listener)
Executes a task on a specific space node.
|
<T> AsyncFutureListener<T> |
DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
Modifier and Type | Class and Description |
---|---|
class |
WaitForAllListener<T>
A listener that can be used to set on several execution and then wait
for all the results (using
WaitForAllListener.waitForResult() . |
class |
WaitForAnyListener<T>
A listener that can be used to set on several execution and then wait
for any of the results (using
WaitForAnyListener.waitForResult() . |
Constructor and Description |
---|
WaitForAllListener(int numberOfResults,
AsyncFutureListener<T> listener)
Constructs a new listener with the number of executions this listener will
be set on with an optional delegate listener.
|
WaitForAnyListener(int numberOfResults,
AsyncFutureListener<T> listener)
Constructs a new listener with the number of executions this listener will
be set on with an optional delegate listener.
|
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) . |
Copyright © GigaSpaces.