Package 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 Phaser

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

Constructor Summary

Constructors

Constructor	Description
AdvancingPhaser(int numParties)

Method Summary

Modifier and Type	Method	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 Details

AdvancingPhaser

public AdvancingPhaser(int numParties)

Method Details

onAdvance

protected boolean onAdvance(int phase,
 int registeredParties)

Overrides:

onAdvance in class Phaser