edu.rice.hj.runtime.forkjoin

Class ForkJoinRuntime

java.lang.Object

edu.rice.hj.runtime.baseruntime.BaseRuntime

edu.rice.hj.runtime.forkjoin.ForkJoinRuntime

All Implemented Interfaces:

HjRuntime

public final class ForkJoinRuntime
extends BaseRuntime

ForkJoinRuntime class.

Author:

Shams Imam (shams@rice.edu) (final shams@rice.edu)

Field Summary

Fields inherited from class edu.rice.hj.runtime.baseruntime.BaseRuntime

deadlockTracker, eventLogger, isolationManager, metricsManager, phaserManager

Constructor Summary

Constructors

Constructor and Description
ForkJoinRuntime() No-args constructor.

Method Summary

Modifier and Type	Method and Description
protected ForkJoinThreadPool[]	allocateExecutors(int numPlaces, int numWorkers, boolean asyncMode)
void	asyncSimt(long estimatedWorkInMiliseconds, int maxParallelism, int start, int end, HjSuspendingProcedureInt2D runnable) asyncSimt

Methods inherited from class edu.rice.hj.runtime.baseruntime.BaseRuntime

abort, abstractMetrics, asyncAwait, asyncPhased, asyncSeqAt, asyncSuspAt, asyncSuspAwait, asyncWhen, checkEureka, cleanup, currentActivity, currentHabaneroActivity, currentPlace, currentThread, doWait, doWork, dumpEventLog, emergencyShutdown, finish, finish, finish, futureAwait, futureSeq, futureSusp, futureSuspAwait, futureWhen, generateActivityName, initialize, isolated, isolated, isolated, isolatedWithReturn, isolatedWithReturn, isolatedWithReturn, isWorkerThread, newBinaryEureka, newConvergenceEureka, newCountEureka, newDataDrivenFuture, newEngineEureka, newEventCount, newExtremaEureka, newFastBarrierEureka, newFinishAccumulator, newPhaser, newSearchEureka, newTimerEureka, newVersionEureka, next, numWorkerThreads, offerEureka, readEureka, readMode, registerListenerForMetrics, retrieveEureka, retrieveEventLogger, runActivity, runKernel, scheduleActivity, scheduleActivity, signal, writeMode

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkJoinRuntime

public ForkJoinRuntime()

No-args constructor.

Method Detail

allocateExecutors

protected ForkJoinThreadPool[] allocateExecutors(int numPlaces,
                                                 int numWorkers,
                                                 boolean asyncMode)

Specified by:

allocateExecutors in class BaseRuntime

asyncSimt

public void asyncSimt(long estimatedWorkInMiliseconds,
                      int maxParallelism,
                      int start,
                      int end,
                      HjSuspendingProcedureInt2D runnable)

asyncSimt

Parameters:

estimatedWorkInMiliseconds - Amount of sequential work in ms estimated for this task

maxParallelism - Amount of parallelism present in the task (assumes linear speedup)

start - Start of range of iterations

end - End of range of iterations

runnable - Body of the async