edu.rice.hj.runtime.forkjoin

Class ForkJoinThread

java.lang.Object

java.lang.Thread

java.util.concurrent.ForkJoinWorkerThread

edu.rice.hj.runtime.forkjoin.ForkJoinThread

All Implemented Interfaces:

BaseThread, Runnable

public class ForkJoinThread
extends ForkJoinWorkerThread
implements BaseThread

Fork-Join worker thread.

Author:

Vincent Cave (vincent.cave@rice.edu), Shams Imam (shams@rice.edu)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected static AtomicInteger	BLOCKING_POINTS Variable to keep track of threads launched by the HJ runtime.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ForkJoinThread(String threadName, ForkJoinThreadPool pool) Creates a ForkJoinWorkerThread operating in the given pool.

Method Summary

Modifier and Type	Method and Description
int[]	activityCounter() activityCounter.
HabaneroActivity	currentActivity() currentActivity.
void	currentActivity(HabaneroActivity newCurrentActivity) currentActivity.
void	stashActivity()
void	threadBlockedNotification(ForkJoinPool.ManagedBlocker managedBlocker) Notification when a thread has been blocked by the HJ runtime by some synchronization constraint.
void	threadUnblockedNotification() Notification when a thread has been unblocked in the HJ runtime by some synchronization constraint.
HabaneroActivity	unstashActivity()

Methods inherited from class java.util.concurrent.ForkJoinWorkerThread

getPool, getPoolIndex, onStart, onTermination, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

BLOCKING_POINTS

protected static final AtomicInteger BLOCKING_POINTS

Variable to keep track of threads launched by the HJ runtime.

Constructor Detail

ForkJoinThread

protected ForkJoinThread(String threadName,
                         ForkJoinThreadPool pool)

Creates a ForkJoinWorkerThread operating in the given pool.

Parameters:

threadName - Name of the thread

pool - the pool this thread works in

Method Detail

activityCounter

public int[] activityCounter()

activityCounter.

Returns:

an array of int.

currentActivity

public final HabaneroActivity currentActivity()

currentActivity.

Specified by:

currentActivity in interface BaseThread

Returns:

the current activity being run by the thread.

currentActivity

public final void currentActivity(HabaneroActivity newCurrentActivity)

currentActivity.

Specified by:

currentActivity in interface BaseThread

Parameters:

newCurrentActivity - the new current activity being run by the thread.

unstashActivity

public final HabaneroActivity unstashActivity()

Specified by:

unstashActivity in interface BaseThread

stashActivity

public final void stashActivity()

Specified by:

stashActivity in interface BaseThread

threadBlockedNotification

public final void threadBlockedNotification(ForkJoinPool.ManagedBlocker managedBlocker)

Notification when a thread has been blocked by the HJ runtime by some synchronization constraint.

Specified by:

threadBlockedNotification in interface BaseThread

Parameters:

managedBlocker - the given blocker

threadUnblockedNotification

public final void threadUnblockedNotification()

Notification when a thread has been unblocked in the HJ runtime by some synchronization constraint.

Specified by:

threadUnblockedNotification in interface BaseThread