523 |
|
}}); |
524 |
|
|
525 |
|
await(pleaseArrive); |
526 |
< |
waitForThreadToEnterWaitState(t); |
526 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
527 |
|
assertEquals(0, phaser.arrive()); |
528 |
|
awaitTermination(t); |
529 |
|
|
551 |
|
}}); |
552 |
|
|
553 |
|
await(pleaseArrive); |
554 |
< |
waitForThreadToEnterWaitState(t); |
554 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
555 |
|
t.interrupt(); |
556 |
|
assertEquals(0, phaser.arrive()); |
557 |
|
awaitTermination(t); |
580 |
|
}}); |
581 |
|
|
582 |
|
await(pleaseArrive); |
583 |
< |
waitForThreadToEnterWaitState(t); |
583 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
584 |
|
Thread.currentThread().interrupt(); |
585 |
|
assertEquals(1, phaser.arriveAndAwaitAdvance()); |
586 |
|
assertTrue(Thread.interrupted()); |
605 |
|
}}); |
606 |
|
|
607 |
|
await(pleaseInterrupt); |
608 |
< |
waitForThreadToEnterWaitState(t); |
608 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
609 |
|
t.interrupt(); |
610 |
|
Thread.currentThread().interrupt(); |
611 |
|
assertEquals(1, phaser.arriveAndAwaitAdvance()); |
780 |
|
assertEquals(THREADS, phaser.getArrivedParties()); |
781 |
|
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
782 |
|
for (Thread thread : threads) |
783 |
< |
waitForThreadToEnterWaitState(thread); |
783 |
> |
assertThreadBlocks(thread, Thread.State.WAITING); |
784 |
|
for (Thread thread : threads) |
785 |
|
assertTrue(thread.isAlive()); |
786 |
|
assertState(phaser, 0, THREADS + 1, 1); |