--- jsr166/src/test/loops/SpinningTieredPhaserLoops.java 2009/11/02 20:23:53 1.2 +++ jsr166/src/test/loops/SpinningTieredPhaserLoops.java 2011/03/15 19:47:06 1.5 @@ -1,7 +1,7 @@ /* * Written by Doug Lea with assistance from members of JCP JSR-166 * Expert Group and released to the public domain, as explained at - * http://creativecommons.org/licenses/publicdomain + * http://creativecommons.org/publicdomain/zero/1.0/ */ import java.util.*; @@ -23,16 +23,12 @@ public class SpinningTieredPhaserLoops { static int tasksPerPhaser = Math.max(NCPUS / 4, 4); static void build(Runnable[] actions, int sz, int lo, int hi, Phaser b) { - int step = (hi - lo) / tasksPerPhaser; - if (step > 1) { - int i = lo; - while (i < hi) { - int r = Math.min(i + step, hi); - build(actions, sz, i, r, new Phaser(b)); - i = r; + if (hi - lo > tasksPerPhaser) { + for (int i = lo; i < hi; i += tasksPerPhaser) { + int j = Math.min(i + tasksPerPhaser, hi); + build(actions, sz, i, j, new Phaser(b)); } - } - else { + } else { for (int i = lo; i < hi; ++i) actions[i] = new PhaserAction(i, b, sz); } @@ -53,7 +49,7 @@ public class SpinningTieredPhaserLoops { public void run() { int n = size; Phaser b = phaser; - for(int i = 0; i < n; ++i) { + for (int i = 0; i < n; ++i) { int p = b.arrive(); while (b.getPhase() == p) { if ((ThreadLocalRandom.current().nextInt() & 127) == 0)