| /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...] |
| /prebuilts/misc/common/robolectric/android-all/ |
| android-all-4.2.2_r1.2-robolectric-r1.jar | |
| android-all-4.3_r2-robolectric-r1.jar | |
| android-all-4.4_r1-robolectric-r2.jar | |
| android-all-5.0.2_r3-robolectric-r0.jar | |
| android-all-5.1.1_r9-robolectric-r2.jar | |
| android-all-6.0.1_r3-robolectric-r1.jar | |
| android-all-7.0.0_r1-robolectric-0.jar | |
| android-all-7.0.0_r1-robolectric-r1.jar | |
| android-all-7.1.0_r7-robolectric-0.jar | |
| android-all-7.1.0_r7-robolectric-r1.jar | |
| /prebuilts/sdk/22/ |
| android.jar | |
| /prebuilts/sdk/23/ |
| android.jar | |
| /prebuilts/sdk/24/ |
| android.jar | |
| /prebuilts/sdk/current/ |
| core.jar | |
| /prebuilts/sdk/system_23/ |
| android.jar | |
