edu.rice.hj.runtime.forkjoin

Class ForkJoinThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ForkJoinPool

edu.rice.hj.runtime.forkjoin.ForkJoinThreadPool

All Implemented Interfaces:

BaseThreadPool, Executor, ExecutorService

public class ForkJoinThreadPool
extends ForkJoinPool
implements BaseThreadPool

Fork-Join pool used by the work-sharing blocking runtime.

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ForkJoinThreadPool.ForkJoinThreadFactory
static class	ForkJoinThreadPool.ForkJoinUncaughtExceptionHandler

Nested classes/interfaces inherited from class java.util.concurrent.ForkJoinPool

ForkJoinPool.ForkJoinWorkerThreadFactory, ForkJoinPool.ManagedBlocker

Field Summary

Fields inherited from class java.util.concurrent.ForkJoinPool

defaultForkJoinWorkerThreadFactory

Constructor Summary

Constructors

Constructor and Description
ForkJoinThreadPool(int numThreads, boolean asyncMode) Constructor for ForkJoinThreadPool.

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command) If current thread is the main thread (i.e. not a ForkJoinWorkerThread), we have to submit the task to the pool Else we fork a new task that will be pushed in ForkJoinWorkerThread's local deque.
int	getNbThreadBlocked() Getter for the field nbThreadBlocked.
String	getStats() getStats.
protected void	reportRuntimeError(String exceptionMsg) reportRuntimeError.
int	staticGetNumThreadBlockingPoints()
int	staticGetNumThreadsCreated()
void	staticSetNumThreadBlockingPoints(int numThreadBlockingPoints)
void	staticSetNumThreadsCreated(int numThreadsCreated)
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.

Methods inherited from class java.util.concurrent.ForkJoinPool

awaitQuiescence, awaitTermination, commonPool, drainTasksTo, execute, getActiveThreadCount, getAsyncMode, getCommonPoolParallelism, getFactory, getParallelism, getPoolSize, getQueuedSubmissionCount, getQueuedTaskCount, getRunningThreadCount, getStealCount, getUncaughtExceptionHandler, hasQueuedSubmissions, invoke, invokeAll, isQuiescent, isShutdown, isTerminated, isTerminating, managedBlock, newTaskFor, newTaskFor, pollSubmission, shutdown, shutdownNow, submit, submit, submit, submit, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.rice.hj.runtime.baseruntime.BaseThreadPool

getParallelism, shutdown, shutdownNow

Constructor Detail

ForkJoinThreadPool

public ForkJoinThreadPool(int numThreads,
                          boolean asyncMode)

Constructor for ForkJoinThreadPool.

Parameters:

numThreads - the parallelism level.

asyncMode - if true, establishes local first-in-first-out scheduling mode for forked tasks that are never joined. This mode may be more appropriate than default locally stack-based mode in applications in which worker threads only process event-style asynchronous tasks. For default value, use false.

Method Detail

getStats

public final String getStats()

getStats.

Specified by:

getStats in interface BaseThreadPool

Returns:

a string representation of the stats of the ThreadPool

threadBlockedNotification

public final void threadBlockedNotification(ForkJoinPool.ManagedBlocker managedBlocker)

Notification when a thread has been blocked by the HJ runtime by some synchronization constraint. The pool may first be expanded to ensure parallelism, and later adjusted.

Parameters:

managedBlocker - the given blocker

reportRuntimeError

protected final void reportRuntimeError(String exceptionMsg)

reportRuntimeError.

Parameters:

exceptionMsg - a String object.

threadUnblockedNotification

public final void threadUnblockedNotification()

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

getNbThreadBlocked

public final int getNbThreadBlocked()

Getter for the field nbThreadBlocked.

Specified by:

getNbThreadBlocked in interface BaseThreadPool

Returns:

the number of threads currently blocked in this place.

execute

public final void execute(Runnable command)

If current thread is the main thread (i.e. not a ForkJoinWorkerThread), we have to submit the task to the pool Else we fork a new task that will be pushed in ForkJoinWorkerThread's local deque.

Specified by:

execute in interface BaseThreadPool

Specified by:

execute in interface Executor

Overrides:

execute in class ForkJoinPool

staticGetNumThreadsCreated

public int staticGetNumThreadsCreated()

Specified by:

staticGetNumThreadsCreated in interface BaseThreadPool

staticSetNumThreadsCreated

public void staticSetNumThreadsCreated(int numThreadsCreated)

Specified by:

staticSetNumThreadsCreated in interface BaseThreadPool

staticGetNumThreadBlockingPoints

public int staticGetNumThreadBlockingPoints()

Specified by:

staticGetNumThreadBlockingPoints in interface BaseThreadPool

staticSetNumThreadBlockingPoints

public void staticSetNumThreadBlockingPoints(int numThreadBlockingPoints)

Specified by:

staticSetNumThreadBlockingPoints in interface BaseThreadPool