edu.rice.hj.runtime.actors

Class LingeringBlockingActivity

java.lang.Object

edu.rice.hj.runtime.forkjoin.BlockingActivity

edu.rice.hj.runtime.actors.LingeringBlockingActivity

All Implemented Interfaces:

LingeringActivity, Runnable

public class LingeringBlockingActivity
extends BlockingActivity
implements LingeringActivity

A concrete implementation of a @see BlockingActivity which delays its execution by claiming not to be ready until forced to be ready.

Author:

Shams Imam (shams@rice.edu), Vivek Sarkar (vsarkar@rice.edu) Created: Feb/20/12 11:30 AM

Field Summary

Fields inherited from class edu.rice.hj.runtime.forkjoin.BlockingActivity

executionException, launchedFinishState, rootFinishState

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LingeringBlockingActivity(String name) Constructor for LingeringBlockingActivity.

Method Summary

Modifier and Type	Method and Description
void	executeBody() This method represents the body of the task.
BlockingActivity	finalizeActivitySpawn(BlockingActivity childActivity) finalizeActivitySpawn.
void	finalizeActorActivitySpawn(BlockingActivity child) finalizeActorActivitySpawn.
void	forceReady() forceReady.
boolean	isReady() isReady.

Methods inherited from class edu.rice.hj.runtime.forkjoin.BlockingActivity

adapt, currentFinishState, finalizeTermination, finalizeTermination, finalizeTerminationCleanup, handleException, join, newFinishState, notifyActivitySpawn, notifyResumption, notifySuspension, prepareToRunInFinish, pushException, registerListener, run, setRootActivityFinishState, startFinish, stopFinish

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.rice.hj.runtime.actors.LingeringActivity

finalizeTermination

Constructor Detail

LingeringBlockingActivity

protected LingeringBlockingActivity(String name)

Constructor for LingeringBlockingActivity.

Parameters:

name - The name of the activity

Method Detail

executeBody

public final void executeBody()

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.

Specified by:

executeBody in class BlockingActivity

isReady

public final boolean isReady()

isReady.

Specified by:

isReady in interface LingeringActivity

Returns:

a boolean.

forceReady

public final void forceReady()

forceReady.

Specified by:

forceReady in interface LingeringActivity

finalizeActivitySpawn

public final BlockingActivity finalizeActivitySpawn(BlockingActivity childActivity)

finalizeActivitySpawn.

Overrides:

finalizeActivitySpawn in class BlockingActivity

Parameters:

childActivity - The child activity being spawned

Returns:

a BlockingActivity object.

finalizeActorActivitySpawn

public final void finalizeActorActivitySpawn(BlockingActivity child)

finalizeActorActivitySpawn.

Prepare the child activity setting up the finish state.

Specified by:

finalizeActorActivitySpawn in interface LingeringActivity

Parameters:

child - the child activity to process actor messages.