final class PhaserSigWaitState
extends java.lang.Object
| 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 and Description |
|---|
PhaserSigWaitState(BlockingPhaser parent,
int phase)
Constructor.
|
| 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() |
private final BlockingPhaser parent
private final int phase
private final java.util.concurrent.atomic.AtomicBoolean active
private final java.util.concurrent.atomic.AtomicInteger numRegisteredSignallers
private final java.util.concurrent.atomic.AtomicInteger numSignalsReceived
private final java.util.concurrent.atomic.AtomicInteger numRegisteredWaiters
private final java.util.concurrent.atomic.AtomicInteger numWaitsReceived
private final java.util.concurrent.atomic.AtomicReference<java.lang.String> nextSingleFlag
private final java.util.concurrent.atomic.AtomicBoolean masterArrived
private final DataDrivenControl<java.lang.Object> signalDdc
private final DataDrivenControl<java.lang.Object> waitDdc
private final CompanionMetrics companionMetrics
PhaserSigWaitState(BlockingPhaser parent, int phase)
parent - phase - protected CompanionMetrics companionMetrics()
protected void activate(int srcPhase)
srcPhase - protected void addSignaller(BlockingActivity activity)
activity - protected void dropSignaller(BlockingActivity activity)
activity - protected void doSignal()
protected void addWaiter(BlockingActivity activity)
activity - protected void dropWaiter(BlockingActivity activity)
activity - protected void doWait()
protected boolean doWaitForNextSinglePhase1(java.lang.String loc)
loc - protected void doWaitForNextSinglePhase2(boolean singleMaster)
singleMaster - private void checkProgress(int srcPhase)
srcPhase - private boolean phaseSignalsComplete()
private boolean phaseWaitsComplete()
protected DataDrivenControl<java.lang.Object> signalDataDrivenControl()
protected DataDrivenControl<java.lang.Object> waitDataDrivenControl()
public java.lang.String toString()
toString in class java.lang.Object