edu.rice.hj.runtime.baseruntime

Class SuspendableActivity

java.lang.Object

edu.rice.hj.runtime.baseruntime.HabaneroActivity

edu.rice.hj.runtime.baseruntime.SuspendableActivity

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

SimtActivity

public abstract class SuspendableActivity
extends HabaneroActivity

Author:

Shams Imam (shams@rice.edu)

Field Summary

Fields

Modifier and Type	Field and Description
protected Coroutine	coroutine Task supporting a continuation.

Fields inherited from class edu.rice.hj.runtime.baseruntime.HabaneroActivity

executionException, launchedFinishState, listenerList, rootFinishState

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SuspendableActivity(String activityName, HjPlace hjPlace) Constructor for HabaneroActivity.

Method Summary

Modifier and Type	Method and Description
protected void	checkSuspendableOperation() Validates the use of a suspendable operation by this activity.
protected boolean	completedExecution() Return true if the task completed execution, else return false if the task was suspended.
abstract void	executeBody() This method represents the body of the task.
void	executeBodyGuarded()
protected void	executeTask()
protected boolean	isAborted()
protected void	prepareToCompleteFinish()
void	prepareToRunInFinish() prepareToRunInFinish.
protected void	processCoroutine()
protected boolean	shouldBypassExecution() Returns true if the activity should be skipped as it has already been executed.

Methods inherited from class edu.rice.hj.runtime.baseruntime.HabaneroActivity

currentFinishState, finalizeActivitySpawn, finalizeTermination, finalizeTermination, finalizeTerminationCleanup, handleException, id, join, name, newFinishState, notifyActivitySpawn, notifyResumption, notifySuspension, place, pushException, registerListener, retrieveTargetFinishState, run, setRootActivityFinishState, startFinish, stopFinish, toString

Methods inherited from class java.lang.Object

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

Field Detail

coroutine

protected Coroutine coroutine

Task supporting a continuation. The invocation strategy to use while executing the activity is wrapped inside the CoroutineProto.

Constructor Detail

SuspendableActivity

protected SuspendableActivity(String activityName,
                              HjPlace hjPlace)

Constructor for HabaneroActivity.

Parameters:

activityName - The name of the activity

Method Detail

checkSuspendableOperation

protected void checkSuspendableOperation()

Validates the use of a suspendable operation by this activity.

Specified by:

checkSuspendableOperation in class HabaneroActivity

shouldBypassExecution

protected final boolean shouldBypassExecution()

Returns true if the activity should be skipped as it has already been executed.

Specified by:

shouldBypassExecution in class HabaneroActivity

Returns:

true if the activity should be skipped as it has already been executed.

prepareToRunInFinish

public final void prepareToRunInFinish()

prepareToRunInFinish.

Specified by:

prepareToRunInFinish in class HabaneroActivity

prepareToCompleteFinish

protected final void prepareToCompleteFinish()

executeTask

protected void executeTask()

Specified by:

executeTask in class HabaneroActivity

processCoroutine

protected void processCoroutine()

executeBodyGuarded

public final void executeBodyGuarded()
                              throws SuspendableException

Throws:

SuspendableException

completedExecution

protected boolean completedExecution()

Description copied from class: HabaneroActivity

Return true if the task completed execution, else return false if the task was suspended.

Specified by:

completedExecution in class HabaneroActivity

Returns:

true if the task completed execution, else return false if the task was suspended.

isAborted

protected boolean isAborted()

executeBody

public abstract void executeBody()
                          throws SuspendableException

This method represents the body of the task. Child classes need to implement this method to allow snippets of code to run potentially in parallel.

Throws:

SuspendableException - to mark that the body contains a suspendable condition.