--- jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2009/11/16 04:16:43 1.6 +++ jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2014/12/18 18:13:06 1.11 @@ -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.*; @@ -51,8 +51,7 @@ public class TimeoutProducerConsumerLoop maxPairs = Integer.parseInt(args[0]); print = true; - int k = 1; - for (int i = 1; i <= maxPairs;) { + for (int k = 1, i = 1; i <= maxPairs;) { System.out.println("Pairs:" + i); oneTest(i, iters); Thread.sleep(100); @@ -64,7 +63,7 @@ public class TimeoutProducerConsumerLoop i = k; } pool.shutdown(); - } + } static void oneTest(int n, int iters) throws Exception { if (print) @@ -109,12 +108,12 @@ public class TimeoutProducerConsumerLoop } - static abstract class Stage implements Runnable { + abstract static class Stage implements Runnable { final int iters; final BlockingQueue queue; final CyclicBarrier barrier; final Phaser lagPhaser; - Stage (BlockingQueue q, CyclicBarrier b, Phaser s, int iters) { + Stage(BlockingQueue q, CyclicBarrier b, Phaser s, int iters) { queue = q; barrier = b; lagPhaser = s;