Searched refs:parties (Results 1 - 4 of 4) sorted by relevance

/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DCyclicBarrier.java51 * for updating shared-state before any of the parties continue.
102 * <p>If the barrier action does not rely on the parties being suspended when
152 /** The number of parties */
153 private final int parties; field in class:CyclicBarrier
160 * Number of parties still waiting. Counts down from parties to 0
161 * on each generation. It is reset to parties on each new
174 count = parties;
184 count = parties;
260 * given number of parties (thread
270 CyclicBarrier(int parties, Runnable barrierAction) argument
286 CyclicBarrier(int parties) argument
[all...]
H A DPhaser.java50 * number of parties <em>registered</em> to synchronize on a phaser
53 * constructors establishing initial numbers of parties), and
67 * number starts at zero, and advances when all parties arrive at the
114 * parties to become zero. As illustrated below, when phasers control
123 * large numbers of parties that would otherwise experience heavy
131 * Whenever the number of registered parties of a child phaser becomes
135 * registered parties becomes zero as the result of an invocation of
140 * only by registered parties, the current state of a phaser may be
142 * #getRegisteredParties} parties in total, of which {@link
145 * parties arriv
514 Phaser(int parties) argument
539 Phaser(Phaser parent, int parties) argument
601 bulkRegister(int parties) argument
[all...]
/openjdk7/jdk/test/java/util/concurrent/Phaser/
H A DPhaseOverflow.java47 int phase, int parties, int unarrived) {
49 equal(parties, phaser.getRegisteredParties());
46 checkState(Phaser phaser, int phase, int parties, int unarrived) argument
H A DFickleRegister.java82 protected boolean onAdvance(int phase, int parties) {

Completed in 59 milliseconds