com.gigaspaces.async.internal

Class CompoundFuture<T,R>

java.lang.Object

com.gigaspaces.async.internal.CompoundFuture<T,R>

All Implemented Interfaces:

AsyncFuture<R>, AsyncFutureListener<T>, Future<R>

public class CompoundFuture<T,R>
extends Object
implements AsyncFuture<R>, AsyncFutureListener<T>

a future implementation used to aggregate results from multiple Futures. it uses a call back from the single Futures to determine whether the action has completed.

Since:

6.5

Author:

asy ronen

Constructor Summary

Constructors

Constructor and Description
CompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer)
CompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
R	get()
R	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	onResult(AsyncResult<T> result) A callback when a result of an async invocation arrives.
void	setListener(AsyncFutureListener<R> listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompoundFuture

public CompoundFuture(AsyncFuture<T>[] futures,
                      AsyncResultsReducer<T,R> reducer)

CompoundFuture

public CompoundFuture(AsyncFuture<T>[] futures,
                      AsyncResultsReducer<T,R> reducer,
                      AsyncResultFilter<T> moderator)

Method Detail

setListener

public void setListener(AsyncFutureListener<R> listener)

Specified by:

setListener in interface AsyncFuture<R>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<R>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<R>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<R>

get

public R get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

get

public R get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

TimeoutException

onResult

public void onResult(AsyncResult<T> result)

Description copied from interface: AsyncFutureListener

A callback when a result of an async invocation arrives.

Specified by:

onResult in interface AsyncFutureListener<T>