edu.rice.hj.runtime.simt

Class WorkStealingThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

edu.rice.hj.runtime.simt.SimtThreadPool

edu.rice.hj.runtime.simt.WorkStealingThreadPool

All Implemented Interfaces:

BaseThreadPool, Executor, ExecutorService

public class WorkStealingThreadPool
extends SimtThreadPool

Author:

Alina Sbirlea (alina@rice.edu)

Nested Class Summary

Nested classes/interfaces inherited from class edu.rice.hj.runtime.simt.SimtThreadPool

SimtThreadPool.SimtThreadFactory

Field Summary

Fields inherited from class edu.rice.hj.runtime.simt.SimtThreadPool

maxThreads, nbThreadBlocked, numThreads, shutdownSignal, simtThreadFactory, workerStats

Constructor Summary

Constructors

Constructor and Description
WorkStealingThreadPool(int numThreads, boolean asyncMode)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command) Main execute
long	getQueuedTaskCount()
ArrayList<Runnable>	shutdownNow()
void	threadBlockedNotification() Notification when a thread has been blocked by the HJ runtime by some synchronization constraint.

Methods inherited from class edu.rice.hj.runtime.simt.SimtThreadPool

awaitTermination, decrementSimtTasks, getNbThreadBlocked, getParallelism, getPoolSize, getStats, incrementSimtTasks, isShutdown, isTerminated, registerThreadStats, reportRuntimeError, shutdown, staticGetNumThreadBlockingPoints, staticGetNumThreadsCreated, staticSetNumThreadBlockingPoints, staticSetNumThreadsCreated, threadUnblockedNotification

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkStealingThreadPool

public WorkStealingThreadPool(int numThreads,
                              boolean asyncMode)

Method Detail

threadBlockedNotification

public final void threadBlockedNotification()

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.

Specified by:

threadBlockedNotification in class SimtThreadPool

execute

public final void execute(Runnable command)

Main execute

Parameters:

command - Task to run

getQueuedTaskCount

public long getQueuedTaskCount()

Returns:

Returns an estimate of the total number of tasks currently held in queues by worker threads (but not including tasks submitted to the pool that have not begun executing).

shutdownNow

public ArrayList<Runnable> shutdownNow()