edu.rice.pcdp.runtime

Class BaseTask.FinishTask

java.lang.Object

java.util.concurrent.ForkJoinTask<T>

java.util.concurrent.CountedCompleter<java.lang.Void>

edu.rice.pcdp.runtime.BaseTask

edu.rice.pcdp.runtime.BaseTask.FinishTask

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<java.lang.Void>

Enclosing class:

BaseTask

public static final class BaseTask.FinishTask
extends BaseTask

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class edu.rice.pcdp.runtime.BaseTask

BaseTask.FinishTask, BaseTask.FutureTask<R>

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.concurrent.atomic.AtomicLong	TASK_COUNTER Count all finish scopes.

Constructor Summary

Constructors

Constructor and Description
FinishTask(java.lang.Runnable setRunnable) Constructor for a finish task.

Method Summary

Modifier and Type	Method and Description
void	awaitCompletion() Wait for all tasks registered on this finish scope to complete.
void	compute()
BaseTask.FinishTask	ief() Fetch the immediately enclosing finish of a task.
void	onCompletion(java.util.concurrent.CountedCompleter<?> caller)
void	pushException(java.lang.Throwable throwable) Push an exception onto the stack.

Methods inherited from class java.util.concurrent.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, exec, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, helpComplete, nextComplete, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, setRawResult, tryComplete

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Field Detail

TASK_COUNTER

protected static final java.util.concurrent.atomic.AtomicLong TASK_COUNTER

Count all finish scopes.

Constructor Detail

FinishTask

public FinishTask(java.lang.Runnable setRunnable)

Constructor for a finish task.

Parameters:

setRunnable - User-defined body of this task.

Method Detail

compute

public void compute()

Specified by:

compute in class java.util.concurrent.CountedCompleter<java.lang.Void>

onCompletion

public void onCompletion(java.util.concurrent.CountedCompleter<?> caller)

Overrides:

onCompletion in class java.util.concurrent.CountedCompleter<java.lang.Void>

awaitCompletion

public void awaitCompletion()

Wait for all tasks registered on this finish scope to complete.

ief

public BaseTask.FinishTask ief()

Description copied from class: BaseTask

Fetch the immediately enclosing finish of a task.

Specified by:

ief in class BaseTask

Returns:

The immediately enclosing finish of the task this is called on. For finish tasks, returns this.

pushException

public void pushException(java.lang.Throwable throwable)

Push an exception onto the stack. Do not decrement finishCount --- this exception was thrown by inline code, not a spawned activity.

Parameters:

throwable - Thrown exception