176 |
|
} |
177 |
|
|
178 |
|
/** |
179 |
< |
* Arrive() on a registered phaser increments phase. |
179 |
> |
* Arrive() on a registered phaser increments phase. |
180 |
|
*/ |
181 |
|
public void testArrive1() { |
182 |
|
Phaser phaser = new Phaser(1); |
235 |
|
phaser.register(); |
236 |
|
phaser.arrive(); |
237 |
|
int p = phaser.getArrivedParties(); |
238 |
< |
assertTrue(p == 1); |
238 |
> |
assertEquals(1, p); |
239 |
|
phaser.arriveAndDeregister(); |
240 |
|
assertTrue(phaser.getArrivedParties() < p); |
241 |
|
} |
252 |
|
assertTrue(parent.getUnarrivedParties() > 0); |
253 |
|
assertTrue(root.getUnarrivedParties() > 0); |
254 |
|
root.arriveAndDeregister(); |
255 |
< |
assertTrue(parent.getUnarrivedParties() == 0); |
256 |
< |
assertTrue(root.getUnarrivedParties() == 0); |
255 |
> |
assertEquals(0, parent.getUnarrivedParties()); |
256 |
> |
assertEquals(0, root.getUnarrivedParties()); |
257 |
|
assertTrue(root.isTerminated() && parent.isTerminated()); |
258 |
|
} |
259 |
|
|
283 |
|
assertTrue(child.getUnarrivedParties() > 0); |
284 |
|
root.register(); |
285 |
|
root.arriveAndDeregister(); |
286 |
< |
assertTrue(parent.getUnarrivedParties() == 0); |
287 |
< |
assertTrue(child.getUnarrivedParties() == 0); |
286 |
> |
assertEquals(0, parent.getUnarrivedParties()); |
287 |
> |
assertEquals(0, child.getUnarrivedParties()); |
288 |
|
assertTrue(root.isTerminated()); |
289 |
|
} |
290 |
|
|
473 |
|
phaser.arriveAndAwaitAdvance(); |
474 |
|
}})); |
475 |
|
} |
476 |
< |
Thread.sleep(LONG_DELAY_MS); |
476 |
> |
Thread.sleep(MEDIUM_DELAY_MS); |
477 |
|
assertEquals(phaser.getArrivedParties(), 3); |
478 |
|
phaser.arriveAndAwaitAdvance(); |
479 |
|
for (Thread thread : threads) |