12 |
|
import java.util.concurrent.CountDownLatch; |
13 |
|
import java.util.concurrent.TimeoutException; |
14 |
|
import static java.util.concurrent.TimeUnit.MILLISECONDS; |
15 |
– |
import static java.util.concurrent.TimeUnit.NANOSECONDS; |
16 |
– |
import java.util.concurrent.atomic.AtomicBoolean; |
15 |
|
import java.util.concurrent.atomic.AtomicInteger; |
16 |
|
|
17 |
|
public class PhaserTest extends JSR166TestCase { |
626 |
|
count.incrementAndGet(); |
627 |
|
assertEquals(2*k+1, phaser.arrive()); |
628 |
|
assertEquals(2*k+2, phaser.awaitAdvance(2*k+1)); |
629 |
< |
assertEquals(count.get(), 4*(k+1)); |
629 |
> |
assertEquals(4*(k+1), count.get()); |
630 |
|
}}})); |
631 |
|
|
632 |
|
for (Thread thread : threads) |