# | Line 478 | Line 478 | public class CyclicBarrierTest extends J | |
---|---|---|
478 | final ExecutorService e = Executors.newFixedThreadPool(nTasks); | |
479 | final Runnable awaiter = () -> { | |
480 | try { | |
481 | < | if (ThreadLocalRandom.current().nextBoolean()) |
481 | > | if (randomBoolean()) |
482 | barrier.await(); | |
483 | else | |
484 | barrier.await(LONG_DELAY_MS, MILLISECONDS); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |