42 |
|
int maxPhase, int parties, int unarrived) { |
43 |
|
assertTrue(phaser.isTerminated()); |
44 |
|
int expectedPhase = maxPhase + Integer.MIN_VALUE; |
45 |
< |
assertState(phaser, expectedPhase, parties, unarrived); |
45 |
> |
assertEquals(expectedPhase, phaser.getPhase()); |
46 |
> |
assertEquals(parties, phaser.getRegisteredParties()); |
47 |
|
assertEquals(expectedPhase, phaser.register()); |
48 |
|
assertEquals(expectedPhase, phaser.arrive()); |
49 |
|
assertEquals(expectedPhase, phaser.arriveAndDeregister()); |
605 |
|
} |
606 |
|
threadsStarted.await(); |
607 |
|
phaser.forceTermination(); |
608 |
+ |
assertTrue(phaser.isTerminated()); |
609 |
|
assertEquals(0, phaser.getPhase() + Integer.MIN_VALUE); |
610 |
|
for (Thread thread : threads) |
611 |
|
awaitTermination(thread, SMALL_DELAY_MS); |
610 |
– |
assertTrue(phaser.isTerminated()); |
611 |
– |
assertTrue(phaser.getPhase() < 0); |
612 |
|
assertEquals(3, phaser.getRegisteredParties()); |
613 |
|
} |
614 |
|
|