equal
deleted
inserted
replaced
177 * |
177 * |
178 * <pre> {@code |
178 * <pre> {@code |
179 * void startTasks(List<Runnable> tasks, int iterations) { |
179 * void startTasks(List<Runnable> tasks, int iterations) { |
180 * Phaser phaser = new Phaser() { |
180 * Phaser phaser = new Phaser() { |
181 * protected boolean onAdvance(int phase, int registeredParties) { |
181 * protected boolean onAdvance(int phase, int registeredParties) { |
182 * return phase >= iterations || registeredParties == 0; |
182 * return phase >= iterations - 1 || registeredParties == 0; |
183 * } |
183 * } |
184 * }; |
184 * }; |
185 * phaser.register(); |
185 * phaser.register(); |
186 * for (Runnable task : tasks) { |
186 * for (Runnable task : tasks) { |
187 * phaser.register(); |
187 * phaser.register(); |