edu.rice.hj.runtime.simt

Class SimtThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

edu.rice.hj.runtime.simt.SimtThreadPool

All Implemented Interfaces:

BaseThreadPool, Executor, ExecutorService

Direct Known Subclasses:

WorkSharingThreadPool, WorkStealingThreadPool

public abstract class SimtThreadPool
extends AbstractExecutorService
implements BaseThreadPool

Author:

Alina Sbirlea (alina@rice.edu)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimtThreadPool.SimtThreadFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected int	maxThreads The maximum number of threads launched by the runtime
protected AtomicInteger	nbThreadBlocked Number of activities that can possibly wait at a given moment.
protected int	numThreads
protected boolean	shutdownSignal
protected int	simtTasks
protected SimtThreadPool.SimtThreadFactory	simtThreadFactory
protected Map<String,int[]>	workerStats

Constructor Summary

Constructors

Constructor and Description
SimtThreadPool(int numThreads, boolean asyncMode)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, TimeUnit unit)
protected void	decrementSimtTasks()
int	getNbThreadBlocked() Getter for the field nbThreadBlocked.
int	getParallelism()
protected int	getPoolSize()
String	getStats() getStats.
protected void	incrementSimtTasks()
boolean	isShutdown()
boolean	isTerminated()
protected void	registerThreadStats(String threadName, int[] statsObject)
protected void	reportRuntimeError(String exceptionMsg) reportRuntimeError.
void	shutdown()
int	staticGetNumThreadBlockingPoints()
int	staticGetNumThreadsCreated()
void	staticSetNumThreadBlockingPoints(int numThreadBlockingPoints)
void	staticSetNumThreadsCreated(int numThreadsCreated)
abstract void	threadBlockedNotification() 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.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

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

execute, shutdownNow

Methods inherited from interface java.util.concurrent.ExecutorService

shutdownNow

Methods inherited from interface java.util.concurrent.Executor

execute

Field Detail

nbThreadBlocked

protected final AtomicInteger nbThreadBlocked

Number of activities that can possibly wait at a given moment.

maxThreads

protected final int maxThreads

The maximum number of threads launched by the runtime

workerStats

protected final Map<String,int[]> workerStats

numThreads

protected int numThreads

simtThreadFactory

protected SimtThreadPool.SimtThreadFactory simtThreadFactory

simtTasks

protected int simtTasks

shutdownSignal

protected boolean shutdownSignal

Constructor Detail

SimtThreadPool

public SimtThreadPool(int numThreads,
                      boolean asyncMode)

Method Detail

registerThreadStats

protected void registerThreadStats(String threadName,
                                   int[] statsObject)

getStats

public final String getStats()

getStats.

Specified by:

getStats in interface BaseThreadPool

Returns:

a string representation of the stats of the ThreadPool

getPoolSize

protected int getPoolSize()

getParallelism

public int getParallelism()

Specified by:

getParallelism in interface BaseThreadPool

threadBlockedNotification

public abstract 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.

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.

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseThreadPool

Specified by:

shutdown in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

decrementSimtTasks

protected void decrementSimtTasks()

incrementSimtTasks

protected void incrementSimtTasks()

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