Searched refs:parties (Results 1 - 4 of 4) sorted by relevance
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | CyclicBarrier.java | 51 * 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 D | Phaser.java | 50 * 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 D | PhaseOverflow.java | 47 int phase, int parties, int unarrived) { 49 equal(parties, phaser.getRegisteredParties()); 46 checkState(Phaser phaser, int phase, int parties, int unarrived) argument
|
H A D | FickleRegister.java | 82 protected boolean onAdvance(int phase, int parties) {
|
Completed in 32 milliseconds