edu.rice.hj.runtime.forkjoin

Class HjAwaitExprBody

java.lang.Object

edu.rice.hj.runtime.forkjoin.HjAwaitExprBody

public final class HjAwaitExprBody
extends Object

A HjAwaitExprBody pairs an await expression (HjExpression.HjAwaitExpression) with the associated runnable body of the async.

Author:

Shams Imam (shams@rice.edu)

Field Summary

Fields

Modifier and Type	Field and Description
protected int	dependentsCount Maintains the count of unique futures used in the await expression.
protected AtomicInteger	resolvedCounter Maintains the count of resolved futures which are used in the await expression.
protected HjLambda<Boolean,?>	runnableBody The runnable body of the await statement

Constructor Summary

Constructors

Constructor and Description
HjAwaitExprBody(edu.rice.hj.experimental.api.HjExpression.HjAwaitExpression expression, HjLambda<Boolean,?> runnableBody) Constructor.

Method Summary

Modifier and Type	Method and Description
void	onFutureResolved(HjFuture<?> aFuture) Callback for when a future has been resolved (successfully or unsuccessfully).

Methods inherited from class java.lang.Object

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

Field Detail

dependentsCount

protected final int dependentsCount

Maintains the count of unique futures used in the await expression.

resolvedCounter

protected final AtomicInteger resolvedCounter

Maintains the count of resolved futures which are used in the await expression.

runnableBody

protected final HjLambda<Boolean,?> runnableBody

The runnable body of the await statement

Constructor Detail

HjAwaitExprBody

public HjAwaitExprBody(edu.rice.hj.experimental.api.HjExpression.HjAwaitExpression expression,
                       HjLambda<Boolean,?> runnableBody)

Constructor.

Parameters:

expression -

runnableBody -

Method Detail

onFutureResolved

public void onFutureResolved(HjFuture<?> aFuture)

Callback for when a future has been resolved (successfully or unsuccessfully).

Parameters:

aFuture - The future instance which has been resolved.