/libcore/jsr166-tests/src/test/java/jsr166/ |
PhaserTest.java | 15 import java.util.concurrent.Phaser; 36 /** Checks state of unterminated phaser. */ 37 protected void assertState(Phaser phaser, 39 assertEquals(phase, phaser.getPhase()); 40 assertEquals(parties, phaser.getRegisteredParties()); 41 assertEquals(unarrived, phaser.getUnarrivedParties()); 42 assertEquals(parties - unarrived, phaser.getArrivedParties()); 43 assertFalse(phaser.isTerminated()); 46 /** Checks state of terminated phaser. * 66 Phaser phaser = new Phaser(); local 139 Phaser phaser = new Phaser(); local 149 Phaser phaser = new Phaser(0); local 177 Phaser phaser = new Phaser(); local 189 Phaser phaser = new Phaser(1); local 239 Phaser phaser = new Phaser(); local 269 final Phaser phaser = new Phaser(size); local 281 Phaser phaser = new Phaser(1); local 291 final Phaser phaser = new Phaser(1); local 307 final Phaser phaser = new Phaser(); local 329 Phaser phaser = new Phaser(1); local [all...] |
DoubleAccumulatorTest.java | 11 import java.util.concurrent.Phaser; 129 Phaser phaser = new Phaser(nthreads + 1); local 131 pool.execute(new AccTask(a, phaser, incs)); 132 phaser.arriveAndAwaitAdvance(); 133 phaser.arriveAndAwaitAdvance(); 142 final Phaser phaser; field in class:DoubleAccumulatorTest.AccTask 145 AccTask(DoubleAccumulator acc, Phaser phaser, int incs) [all...] |
LongAccumulatorTest.java | 11 import java.util.concurrent.Phaser; 129 Phaser phaser = new Phaser(nthreads + 1); local 131 pool.execute(new AccTask(a, phaser, incs)); 132 phaser.arriveAndAwaitAdvance(); 133 phaser.arriveAndAwaitAdvance(); 142 final Phaser phaser; field in class:LongAccumulatorTest.AccTask 145 AccTask(LongAccumulator acc, Phaser phaser, int incs) [all...] |
/frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/ |
TestContentResolver.java | 27 import java.util.concurrent.Phaser; 33 private final Map<Uri, Phaser> mPhasers = new HashMap<>(); 54 private synchronized Phaser getPhaser(Uri uri) { 55 Phaser phaser = mPhasers.get(uri); local 56 if (phaser == null) { 57 phaser = new Phaser(1); 58 mPhasers.put(uri, phaser); 60 return phaser; [all...] |
/libcore/ojluni/src/main/java/java/util/concurrent/ |
Phaser.java | 48 * number of parties <em>registered</em> to synchronize on a phaser 61 * Phaser} may be repeatedly awaited. Method {@link 64 * generation of a phaser has an associated phase number. The phase 66 * phaser, wrapping around to zero after reaching {@code 68 * control of actions upon arrival at a phaser and upon awaiting 77 * number</em>; that is, the phase number of the phaser to which 89 * the phaser advances to (or is already at) a different phase. 95 * state of the phaser. If necessary, you can perform any 105 * <p><b>Termination.</b> A phaser may enter a <em>termination</em> 130 * Whenever the number of registered parties of a child phaser become 1085 final Phaser phaser; field in class:Phaser.QNode [all...] |