org.apache.ignite.internal

Class ComputeTaskInternalFuture<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.ComputeTaskInternalFuture<R>

Type Parameters:

R - Type of the task result returning from ComputeTask.reduce(List) method.

All Implemented Interfaces:

Externalizable, Serializable, IgniteInternalFuture<R>

public class ComputeTaskInternalFuture<R>
extends GridFutureAdapter<R>

This class provide implementation for task future.

See Also:

Serialized Form

Nested Class Summary

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

AbstractQueuedSynchronizer.ConditionObject

Field Summary

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

log

Constructor Summary

Constructors

Constructor and Description
ComputeTaskInternalFuture() Required by Externalizable.
ComputeTaskInternalFuture(ComputeTaskSession ses, GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel() Default no-op implementation that always returns false.
boolean	cancelOnMasterLeave() Cancel task on master leave event.
static <R> ComputeTaskInternalFuture<R>	finishedFuture(GridKernalContext ctx, Class<?> taskCls, IgniteCheckedException e)
ComputeTaskSession	getTaskSession() Gets task timeout.
ComputeTaskFuture<R>	publicFuture()
String	toString()

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

chain, checkValid, concurrentNotify, concurrentNotify, duration, endTime, error, get, get, get, get0, isCancelled, isDone, isFailed, isValid, listenAsync, onCancelled, onDone, onDone, onDone, onDone, readExternal, result, startTime, stopListenAsync, syncNotify, syncNotify, tryAcquireShared, tryReleaseShared, writeExternal

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

ComputeTaskInternalFuture

public ComputeTaskInternalFuture()

Required by Externalizable.

ComputeTaskInternalFuture

public ComputeTaskInternalFuture(ComputeTaskSession ses,
                         GridKernalContext ctx)

Parameters:

ses - Task session instance.

ctx - Kernal context.

Method Detail

finishedFuture

public static <R> ComputeTaskInternalFuture<R> finishedFuture(GridKernalContext ctx,
                                              Class<?> taskCls,
                                              IgniteCheckedException e)

Parameters:

ctx - Context.

taskCls - Task class.

e - Error.

Returns:

Finished task future.

publicFuture

public ComputeTaskFuture<R> publicFuture()

Returns:

Future returned by public API.

getTaskSession

public ComputeTaskSession getTaskSession()

Gets task timeout.

Returns:

Task timeout.

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.

cancelOnMasterLeave

public boolean cancelOnMasterLeave()
                            throws IgniteCheckedException

Cancel task on master leave event. Does not send cancel request to remote jobs and invokes master-leave callback on local jobs.

Returns:

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

Throws:

IgniteCheckedException - If failed.

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<R>