edu.rice.hj.runtime.phasers

Class PhaserSigWaitState

java.lang.Object

edu.rice.hj.runtime.phasers.PhaserSigWaitState

final class PhaserSigWaitState
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	active
private CompanionMetrics	companionMetrics
private java.util.concurrent.atomic.AtomicBoolean	masterArrived
private java.util.concurrent.atomic.AtomicReference<java.lang.String>	nextSingleFlag
private java.util.concurrent.atomic.AtomicInteger	numRegisteredSignallers
private java.util.concurrent.atomic.AtomicInteger	numRegisteredWaiters
private java.util.concurrent.atomic.AtomicInteger	numSignalsReceived
private java.util.concurrent.atomic.AtomicInteger	numWaitsReceived
private BlockingPhaser	parent
private int	phase
private DataDrivenControl<java.lang.Object>	signalDdc
private DataDrivenControl<java.lang.Object>	waitDdc

Constructor Summary

Constructors

Constructor and Description
PhaserSigWaitState(BlockingPhaser parent, int phase) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	activate(int srcPhase)
protected void	addSignaller(BlockingActivity activity)
protected void	addWaiter(BlockingActivity activity)
private void	checkProgress(int srcPhase)
protected CompanionMetrics	companionMetrics()
protected void	doSignal()
protected void	doWait()
protected boolean	doWaitForNextSinglePhase1(java.lang.String loc)
protected void	doWaitForNextSinglePhase2(boolean singleMaster)
protected void	dropSignaller(BlockingActivity activity)
protected void	dropWaiter(BlockingActivity activity)
private boolean	phaseSignalsComplete()
private boolean	phaseWaitsComplete()
protected DataDrivenControl<java.lang.Object>	signalDataDrivenControl()
java.lang.String	toString()
protected DataDrivenControl<java.lang.Object>	waitDataDrivenControl()

Methods inherited from class java.lang.Object

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

Field Detail

parent

private final BlockingPhaser parent

phase

private final int phase

active

private final java.util.concurrent.atomic.AtomicBoolean active

numRegisteredSignallers

private final java.util.concurrent.atomic.AtomicInteger numRegisteredSignallers

numSignalsReceived

private final java.util.concurrent.atomic.AtomicInteger numSignalsReceived

numRegisteredWaiters

private final java.util.concurrent.atomic.AtomicInteger numRegisteredWaiters

numWaitsReceived

private final java.util.concurrent.atomic.AtomicInteger numWaitsReceived

nextSingleFlag

private final java.util.concurrent.atomic.AtomicReference<java.lang.String> nextSingleFlag

masterArrived

private final java.util.concurrent.atomic.AtomicBoolean masterArrived

signalDdc

private final DataDrivenControl<java.lang.Object> signalDdc

waitDdc

private final DataDrivenControl<java.lang.Object> waitDdc

companionMetrics

private final CompanionMetrics companionMetrics

Constructor Detail

PhaserSigWaitState

PhaserSigWaitState(BlockingPhaser parent,
                   int phase)

Constructor.

Parameters:

parent -

phase -

Method Detail

companionMetrics

protected CompanionMetrics companionMetrics()

activate

protected void activate(int srcPhase)

Parameters:

srcPhase -

addSignaller

protected void addSignaller(BlockingActivity activity)

Parameters:

activity -

dropSignaller

protected void dropSignaller(BlockingActivity activity)

Parameters:

activity -

doSignal

protected void doSignal()

addWaiter

protected void addWaiter(BlockingActivity activity)

Parameters:

activity -

dropWaiter

protected void dropWaiter(BlockingActivity activity)

Parameters:

activity -

doWait

protected void doWait()

doWaitForNextSinglePhase1

protected boolean doWaitForNextSinglePhase1(java.lang.String loc)

Parameters:

loc -

Returns:

doWaitForNextSinglePhase2

protected void doWaitForNextSinglePhase2(boolean singleMaster)

Parameters:

singleMaster -

checkProgress

private void checkProgress(int srcPhase)

Parameters:

srcPhase -

phaseSignalsComplete

private boolean phaseSignalsComplete()

Returns:

phaseWaitsComplete

private boolean phaseWaitsComplete()

Returns:

signalDataDrivenControl

protected DataDrivenControl<java.lang.Object> signalDataDrivenControl()

Returns:

waitDataDrivenControl

protected DataDrivenControl<java.lang.Object> waitDataDrivenControl()

Returns:

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object