org.apache.beam.sdk.fn.stream

Class AdvancingPhaser

java.lang.Object

java.util.concurrent.Phaser

org.apache.beam.sdk.fn.stream.AdvancingPhaser

public final class AdvancingPhaser
extends java.util.concurrent.Phaser

A Phaser which never terminates. The default Phaser implementation terminates after the first advancement.

Constructor Summary

Constructors

Constructor and Description
AdvancingPhaser(int numParties)

Method Summary

Modifier and Type	Method and Description
protected boolean	onAdvance(int phase, int registeredParties)

Methods inherited from class java.util.concurrent.Phaser

arrive, arriveAndAwaitAdvance, arriveAndDeregister, awaitAdvance, awaitAdvanceInterruptibly, awaitAdvanceInterruptibly, bulkRegister, forceTermination, getArrivedParties, getParent, getPhase, getRegisteredParties, getRoot, getUnarrivedParties, isTerminated, register, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AdvancingPhaser

public AdvancingPhaser(int numParties)

Method Detail

onAdvance

protected boolean onAdvance(int phase,
                            int registeredParties)

Overrides:

onAdvance in class java.util.concurrent.Phaser