--- jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2010/09/27 19:15:16 1.6 +++ jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2015/08/10 03:13:33 1.10 @@ -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.concurrent.*; @@ -36,8 +36,7 @@ public class SingleProducerMultipleConsu warmup(); print = true; - int k = 1; - for (int i = 1; i <= maxn;) { + for (int k = 1, i = 1; i <= maxn;) { System.out.println("Consumers:" + i); oneTest(i, ITERS); if (i == k) { @@ -49,7 +48,7 @@ public class SingleProducerMultipleConsu } pool.shutdown(); - } + } static void warmup() throws Exception { print = false; @@ -128,7 +127,6 @@ public class SingleProducerMultipleConsu if (print) System.out.print("ArrayBlockingQueue(fair)"); oneRun(new ArrayBlockingQueue(POOL_SIZE, true), n, fairIters); - } abstract static class Stage implements Runnable { @@ -170,7 +168,6 @@ public class SingleProducerMultipleConsu static class Consumer extends Stage { Consumer(BlockingQueue q, CyclicBarrier b, int iters) { super(q, b, iters); - } public void run() {