# | Line 470 | Line 470 | public class PhaserTest extends JSR166Te | |
---|---|---|
470 | threads.add(newStartedThread(new CheckedRunnable() { | |
471 | public void realRun() throws InterruptedException { | |
472 | phaser.register(); | |
473 | < | phaser.arrive(); |
473 | > | phaser.arriveAndAwaitAdvance(); |
474 | }})); | |
475 | } | |
476 | Thread.sleep(LONG_DELAY_MS); | |
477 | assertEquals(phaser.getArrivedParties(), 3); | |
478 | < | phaser.arrive(); |
478 | > | phaser.arriveAndAwaitAdvance(); |
479 | for (Thread thread : threads) | |
480 | thread.join(); | |
481 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |