org.apache.ignite.internal.util.future

Class GridCompoundFuture<T,R>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

org.apache.ignite.internal.util.future.GridFutureAdapter<R>

org.apache.ignite.internal.util.future.GridCompoundFuture<T,R>

All Implemented Interfaces:

Serializable, IgniteInternalFuture<R>

Direct Known Subclasses:

GridCompoundIdentityFuture, GridDhtForceKeysFuture, GridDhtTxPrepareFuture

public class GridCompoundFuture<T,R>
extends GridFutureAdapter<R>

Future composed of multiple inner futures.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

Constructor Summary

Constructors

Constructor and Description
GridCompoundFuture()
GridCompoundFuture(IgniteReducer<T,R> rdc)
GridCompoundFuture(IgniteReducer<T,R> rdc, Iterable<IgniteInternalFuture<T>> futs)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(IgniteInternalFuture<T> fut) Adds a future to this compound future.
void	addAll(IgniteInternalFuture<T>... futs) Adds futures to this compound future.
void	addAll(Iterable<IgniteInternalFuture<T>> futs) Adds futures to this compound future.
boolean	cancel() Default no-op implementation that always returns false.
Collection<IgniteInternalFuture<T>>	futures() Gets collection of futures.
boolean	hasPending() Checks if there are pending futures.
void	ignoreChildFailures(Class<? extends Throwable>... ignoreChildFailures)
boolean	initialized()
void	markInitialized() Mark this future as initialized.
Collection<IgniteInternalFuture<T>>	pending() Gets pending (unfinished) futures.
IgniteReducer<T,R>	reducer() Gets optional reducer.
void	reducer(IgniteReducer<T,R> rdc) Sets optional reducer.
String	toString()

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

chain, duration, endTime, error, get, get, get, get0, ignoreInterrupts, isCancelled, isDone, isFailed, listen, onCancelled, onDone, onDone, onDone, onDone, result, startTime, tryAcquireShared, tryReleaseShared

Methods inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

acquire, acquireInterruptibly, acquireShared, acquireSharedInterruptibly, compareAndSetState, getExclusiveQueuedThreads, getFirstQueuedThread, getQueuedThreads, getQueueLength, getSharedQueuedThreads, getState, getWaitingThreads, getWaitQueueLength, hasContended, hasQueuedPredecessors, hasQueuedThreads, hasWaiters, isHeldExclusively, isQueued, owns, release, releaseShared, setState, tryAcquire, tryAcquireNanos, tryAcquireSharedNanos, tryRelease

Methods inherited from class java.util.concurrent.locks.AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCompoundFuture

public GridCompoundFuture()

GridCompoundFuture

public GridCompoundFuture(@Nullable
                  IgniteReducer<T,R> rdc)

Parameters:

rdc - Reducer.

GridCompoundFuture

public GridCompoundFuture(@Nullable
                  IgniteReducer<T,R> rdc,
                  @Nullable
                  Iterable<IgniteInternalFuture<T>> futs)

Parameters:

rdc - Reducer to add.

futs - Futures to add.

Method Detail

cancel

public boolean cancel()
               throws IgniteCheckedException

Default no-op implementation that always returns false. Futures that do support cancellation should override this method and call GridFutureAdapter.onCancelled() callback explicitly if cancellation indeed did happen.

Specified by:

cancel in interface IgniteInternalFuture<R>

Overrides:

cancel in class GridFutureAdapter<R>

Returns:

True if future was canceled (i.e. was not finished prior to this call).

Throws:

IgniteCheckedException - If cancellation failed.

futures

public Collection<IgniteInternalFuture<T>> futures()

Gets collection of futures.

Returns:

Collection of futures.

pending

public Collection<IgniteInternalFuture<T>> pending()

Gets pending (unfinished) futures.

Returns:

Pending futures.

ignoreChildFailures

public void ignoreChildFailures(Class<? extends Throwable>... ignoreChildFailures)

Parameters:

ignoreChildFailures - Flag indicating whether compound future should ignore child futures failures.

hasPending

public boolean hasPending()

Checks if there are pending futures. This is not the same as GridFutureAdapter.isDone() because child classes may override GridFutureAdapter.onDone(Object, Throwable) call and delay completion.

Returns:

True if there are pending futures.

initialized

public boolean initialized()

Returns:

True if this future was initialized. Initialization happens when markInitialized() method is called on future.

add

public void add(IgniteInternalFuture<T> fut)

Adds a future to this compound future.

Parameters:

fut - Future to add.

addAll

public void addAll(@Nullable
          IgniteInternalFuture<T>... futs)

Adds futures to this compound future.

Parameters:

futs - Futures to add.

addAll

public void addAll(@Nullable
          Iterable<IgniteInternalFuture<T>> futs)

Adds futures to this compound future.

Parameters:

futs - Futures to add.

reducer

@Nullable
public IgniteReducer<T,R> reducer()

Gets optional reducer.

Returns:

Optional reducer.

reducer

public void reducer(@Nullable
           IgniteReducer<T,R> rdc)

Sets optional reducer.

Parameters:

rdc - Optional reducer.

markInitialized

public void markInitialized()

Mark this future as initialized.

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<R>