# | Line 150 | Line 150 | import java.util.concurrent.locks.LockSu | |
---|---|---|
150 | * void startTasks(List<Runnable> tasks, int iterations) { | |
151 | * Phaser phaser = new Phaser() { | |
152 | * protected boolean onAdvance(int phase, int registeredParties) { | |
153 | < | * return phase >= iterations || registeredParties == 0; |
153 | > | * return phase >= iterations - 1 || registeredParties == 0; |
154 | * } | |
155 | * }; | |
156 | * phaser.register(); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |