edu.rice.hj.runtime.actors

Class RunnableBlockingActivity

java.lang.Object

edu.rice.hj.runtime.forkjoin.BlockingActivity

edu.rice.hj.runtime.actors.RunnableBlockingActivity

All Implemented Interfaces:

Runnable

public class RunnableBlockingActivity
extends BlockingActivity

A concrete implementation of a @see BlockingActivity which accepts a runnable block to execute.

Author:

Shams Imam (shams@rice.edu), Vivek Sarkar (vsarkar@rice.edu)

Field Summary

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

executionException, launchedFinishState, rootFinishState

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RunnableBlockingActivity(String name, Runnable pRunnable) Constructor for RunnableBlockingActivity.

Method Summary

Modifier and Type	Method and Description
void	executeBody() This method represents the body of the task.
void	finalizeTermination() finalizeTermination.
void	finalizeTermination(Throwable throwable) finalizeTermination.

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

adapt, currentFinishState, finalizeActivitySpawn, 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

Constructor Detail

RunnableBlockingActivity

protected RunnableBlockingActivity(String name,
                                   Runnable pRunnable)

Constructor for RunnableBlockingActivity.

Parameters:

name - Name of the activity

pRunnable - The runnable block to execute

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

finalizeTermination

public final void finalizeTermination()

finalizeTermination.

Overrides:

finalizeTermination in class BlockingActivity

finalizeTermination

public final void finalizeTermination(Throwable throwable)

finalizeTermination.

Overrides:

finalizeTermination in class BlockingActivity

Parameters:

throwable - The exception thrown while executing the body of the activity.