Package | Description |
---|---|
edu.rice.hj |
The base package for all habanero-java related items.
|
edu.rice.hj.api |
The base package for all Habanero-Java API.
|
edu.rice.hj.experimental | |
edu.rice.hj.experimental.api | |
edu.rice.hj.runtime.baseruntime | |
edu.rice.hj.runtime.javafj | |
edu.rice.hj.runtime.metrics |
The base package for the habanero-java abstract metrics.
|
edu.rice.hj.runtime.phasers |
The base package for the habanero-java phaser support.
|
edu.rice.hj.runtime.sequential |
The base package for a sequential implementation of the HJ runtime.
|
Modifier and Type | Method and Description |
---|---|
static <V> HjFuture<V> |
Module1.future(HjSuspendingCallable<V> callable)
Construct to create an asynchronous task that returns a result which will be available in the futureNb.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(List<HjFuture<T>> dependences,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <V> HjFuture<V> |
Module0.futureNb(HjCallable<V> callable)
Construct to create an asynchronous task that returns a result which will be available in the futureNb.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(List<HjFuture<T>> dependences,
HjCallable<V> callable)
futureNbAwait.
|
static <V> HjFuture<V> |
Module0.futureNbSeq(boolean sequentialize,
HjCallable<V> callable)
Construct to create an asynchronous task that returns a result which will be available in the future.
|
static <V> HjFuture<V> |
Module0.futureNbSeq(boolean sequentialize,
HjCallable<V> seqCallable,
HjCallable<V> parCallable)
Similar to the regular
Module0.futureNb(edu.rice.hj.api.HjCallable) except that the boolean
condition is used as a tuning parameter to determine if the future should just be executed sequentially (when the
condition is true) in the parent task. |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when both the futures are resolved.
|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when both the futures are resolved.
|
static <T> void |
Module1.asyncAwait(HjFuture<T> f1,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when the futureNb is resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when all the futures are resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when both the futures are resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when both the futures are resolved.
|
static <T> void |
Module0.asyncNbAwait(HjFuture<T> f1,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when the futureNb is resolved.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(HjFuture<T> f1,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjCallable<V> callable)
futureNbAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(HjFuture<T> f1,
HjFuture<T> f2,
HjFuture<T> f3,
HjCallable<V> callable)
futureNbAwait.
|
static boolean[] |
Module0.waitAll(HjFuture[] futures)
Blocks until all of the operations associated with the active requests in the array have completed.
|
static boolean[] |
Module0.waitAny(HjFuture[] futures)
Blocks until one of the operations associated with the active requests in the array has completed successfully.
|
Modifier and Type | Method and Description |
---|---|
static <T> void |
Module1.asyncAwait(List<HjFuture<T>> dependences,
HjSuspendable suspendable)
Construct to create an asynchronous task which is executed when all the futureNb are resolved.
|
static <T> void |
Module0.asyncNbAwait(List<HjFuture<T>> dependences,
HjRunnable runnable)
Construct to create an asynchronous task which is executed when all the futureNb are resolved.
|
static <T,V> HjFuture<V> |
Module1.futureAwait(List<HjFuture<T>> dependences,
HjSuspendingCallable<V> callable)
futureAwait.
|
static <T,V> HjFuture<V> |
Module0.futureNbAwait(List<HjFuture<T>> dependences,
HjCallable<V> callable)
futureNbAwait.
|
Modifier and Type | Interface and Description |
---|---|
interface |
HjDataDrivenFuture<V>
A Future that may be explicitly completed by setting its value using the
put() method. |
Modifier and Type | Method and Description |
---|---|
<T,V> HjFuture<V> |
HjRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<V> HjFuture<V> |
HjRuntime.futureSeq(boolean sequentialize,
HjCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<V> HjFuture<V> |
HjRuntime.futureSusp(HjSuspendingCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<T,V> HjFuture<V> |
HjRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a future. |
<V> HjFuture<V> |
HjRuntime.futureWhen(HjExpression.HjAwaitExpression expression,
HjCallable<V> callable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
<T> void |
HjRuntime.asyncAwait(List<HjFuture<T>> dependences,
HjRunnable runnable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T> void |
HjRuntime.asyncSuspAwait(List<HjFuture<T>> dependences,
HjSuspendable suspendable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T,V> HjFuture<V> |
HjRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<T,V> HjFuture<V> |
HjRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a future. |
Modifier and Type | Method and Description |
---|---|
static <V> HjFuture<V> |
ModuleZ.futureWhen(HjExpression.HjAwaitExpression expression,
HjCallable<V> runnable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
static <V> HjFuture<V> |
ModuleZ.futureWhen(HjExpression.HjBooleanExpression expression,
HjCallable<V> runnable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
static <V> HjFuture<V> |
ModuleZ.futureWhen(HjFuture<?> future,
HjCallable<V> runnable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
static void |
ModuleZ.asyncWhen(HjFuture<?> future,
HjRunnable runnable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
static <V> HjFuture<V> |
ModuleZ.futureWhen(HjFuture<?> future,
HjCallable<V> runnable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
Set<HjFuture> |
HjExpression.HjAwaitExpression.dependents()
Returns the
HjFuture instances used in the wrapped boolean expression. |
Modifier and Type | Method and Description |
---|---|
static HjExpression.HjBooleanExpression |
HjExpression.and(HjFuture<?>[] futures)
Returns an
HjExpression.HjBooleanExpression representing an AND expression tree. |
static HjExpression.HjBooleanExpression |
HjExpression.and(HjFuture<?> left,
HjFuture<?> right)
Returns an
HjExpression.HjBooleanExpression representing an AND expression. |
static HjExpression.HjBooleanExpression |
HjExpression.and(HjFuture<?> left,
HjFuture<?> right)
Returns an
HjExpression.HjBooleanExpression representing an AND expression. |
static HjExpression.HjBooleanExpression |
HjExpression.countEqualTo(HjFuture<?>[] futures,
int count)
Returns an
HjExpression.HjBooleanExpression representing a COUNT(futures) == count expression. |
static HjExpression.HjBooleanExpression |
HjExpression.countGreaterOrEqualTo(HjFuture<?>[] futures,
int count)
Returns an
HjExpression.HjBooleanExpression representing a COUNT(futures) >= count expression. |
static HjExpression.HjBooleanExpression |
HjExpression.countGreaterThan(HjFuture<?>[] futures,
int count)
Returns an
HjExpression.HjBooleanExpression representing a COUNT(futures) > count expression. |
static HjExpression.HjBooleanExpression |
HjExpression.countLesserOrEqualTo(HjFuture<?>[] futures,
int count)
Returns an
HjExpression.HjBooleanExpression representing a COUNT(futures) <= count expression. |
static HjExpression.HjBooleanExpression |
HjExpression.countLesserThan(HjFuture<?>[] futures,
int count)
Returns an
HjExpression.HjBooleanExpression representing a COUNT(futures) < count expression. |
static HjExpression.HjBooleanExpression |
HjExpression.leaf(HjFuture<?> aFuture)
Returns an
HjExpression.HjBooleanExpression wrapping an HjFuture instance. |
static HjExpression.HjBooleanExpression |
HjExpression.not(HjFuture<?> arg)
Returns an
HjExpression.HjBooleanExpression representing a NOT expression. |
static HjExpression.HjBooleanExpression |
HjExpression.or(HjFuture<?>[] futures)
Returns an
HjExpression.HjBooleanExpression representing an OR expression tree. |
static HjExpression.HjBooleanExpression |
HjExpression.or(HjFuture<?> left,
HjFuture<?> right)
Returns an
HjExpression.HjBooleanExpression representing an OR expression. |
static HjExpression.HjBooleanExpression |
HjExpression.or(HjFuture<?> left,
HjFuture<?> right)
Returns an
HjExpression.HjBooleanExpression representing an OR expression. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
HjExpression.HjBooleanExpression.collectDependents(Set<HjFuture> accumulatedSet)
Accumulates all the
HjFuture instances used in this expression.xz |
Modifier and Type | Class and Description |
---|---|
class |
ParallelDataDrivenFuture<ValueType>
Parallel implementation of a HjDataDrivenFuture
|
class |
ParallelFuture<ValueType>
A thread blocking implementation of HjFuture.
|
Modifier and Type | Method and Description |
---|---|
<T,V> HjFuture<V> |
BaseRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<V> HjFuture<V> |
BaseRuntime.futureSeq(boolean sequentialize,
HjCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<V> HjFuture<V> |
BaseRuntime.futureSusp(HjSuspendingCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<T,V> HjFuture<V> |
BaseRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a future. |
<V> HjFuture<V> |
BaseRuntime.futureWhen(HjExpression.HjAwaitExpression expression,
HjCallable<V> hjCallable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
void |
HjAwaitExprBody.onFutureResolved(HjFuture<?> aFuture)
Callback for when a futureNb has been resolved (successfully or unsuccessfully).
|
Modifier and Type | Method and Description |
---|---|
<T> void |
BaseRuntime.asyncAwait(List<HjFuture<T>> dependencies,
HjRunnable runnable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T> void |
BaseRuntime.asyncSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendable suspendable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T,V> HjFuture<V> |
BaseRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<T,V> HjFuture<V> |
BaseRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a future. |
<T> void |
EventLogger.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies) |
<T> void |
DeadlockTracker.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies)
Callback for the event when all the activities dependencies are ready.
|
<T> void |
ActivityListeners.ActivityListener.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies)
Callback for the event when all the activities dependencies are ready.
|
<T> void |
ActivityListeners.ActivityListenerList.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies)
Callback for the event when all the activities dependencies are ready.
|
<T> void |
ActivityListeners.ActivityListenerAdapter.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies) |
Modifier and Type | Method and Description |
---|---|
<T,V> HjFuture<V> |
JavaForkJoinRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<V> HjFuture<V> |
JavaForkJoinRuntime.futureSeq(boolean sequentialize,
HjCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<V> HjFuture<V> |
JavaForkJoinRuntime.futureSusp(HjSuspendingCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<T,V> HjFuture<V> |
JavaForkJoinRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable) |
<V> HjFuture<V> |
JavaForkJoinRuntime.futureWhen(HjExpression.HjAwaitExpression expression,
HjCallable<V> callable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
<T> void |
JavaForkJoinRuntime.asyncAwait(List<HjFuture<T>> dependences,
HjRunnable runnable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T> void |
JavaForkJoinRuntime.asyncSuspAwait(List<HjFuture<T>> dependences,
HjSuspendable suspendable) |
<T,V> HjFuture<V> |
JavaForkJoinRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<T,V> HjFuture<V> |
JavaForkJoinRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable) |
Modifier and Type | Method and Description |
---|---|
<T> void |
AbstractMetricsManager.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies)
Callback for the event when all the activities dependencies are ready.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
PhaserManagerImpl.onActivityDependenciesReady(HabaneroActivity activity,
List<HjFuture<T>> dependencies)
Callback for the event when all the activities dependencies are ready.
|
Modifier and Type | Method and Description |
---|---|
<T,V> HjFuture<V> |
SequentialRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<V> HjFuture<V> |
SequentialRuntime.futureSeq(boolean sequentialize,
HjCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<V> HjFuture<V> |
SequentialRuntime.futureSusp(HjSuspendingCallable<V> callable)
Creates an asynchronous task and returns the futureNb object representing the value of the computation.
|
<T,V> HjFuture<V> |
SequentialRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable) |
<V> HjFuture<V> |
SequentialRuntime.futureWhen(HjExpression.HjAwaitExpression expression,
HjCallable<V> callable)
Mechanism to create an asynchronous task where the await expression is designed to coordinate relationships of
this parallel tasks with other tasks (using the
HjFuture handles. |
Modifier and Type | Method and Description |
---|---|
<T> void |
SequentialRuntime.asyncAwait(List<HjFuture<T>> dependences,
HjRunnable runnable)
Will execute the body of the runnable only after the dependences have been satisfied.
|
<T> void |
SequentialRuntime.asyncSuspAwait(List<HjFuture<T>> dependences,
HjSuspendable suspendable) |
<T,V> HjFuture<V> |
SequentialRuntime.futureAwait(List<HjFuture<T>> dependencies,
HjCallable<V> callable)
Equivalent of
HjRuntime.asyncAwait(java.util.List, HjRunnable) which returns a futureNb. |
<T,V> HjFuture<V> |
SequentialRuntime.futureSuspAwait(List<HjFuture<T>> dependencies,
HjSuspendingCallable<V> callable) |
Copyright © 2015 Rice University - Department of Computer Science. All rights reserved.