--- jsr166/src/test/loops/MultipleProducersSingleConsumerLoops.java 2010/09/01 07:47:27 1.6 +++ jsr166/src/test/loops/MultipleProducersSingleConsumerLoops.java 2015/08/10 03:13:33 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.*; @@ -54,8 +54,7 @@ public class MultipleProducersSingleCons warmup(); print = true; - int k = 1; - for (int i = 1; i <= maxn;) { + for (int k = 1, i = 1; i <= maxn;) { System.out.println("Producers:" + i); oneTest(i, ITERS); if (i == k) { @@ -121,7 +120,6 @@ public class MultipleProducersSingleCons System.out.print("SynchronousQueue "); oneRun(new SynchronousQueue(), n, iters); - Thread.sleep(100); // System.gc(); if (print) System.out.print("SynchronousQueue(fair) "); @@ -146,11 +144,9 @@ public class MultipleProducersSingleCons if (print) System.out.print("ArrayBlockingQueue(fair)"); oneRun(new ArrayBlockingQueue(POOL_SIZE, true), n, fairIters); - - } - static abstract class Stage implements Runnable { + abstract static class Stage implements Runnable { final int iters; final BlockingQueue queue; final CyclicBarrier barrier; @@ -230,7 +226,6 @@ public class MultipleProducersSingleCons } - static void oneRun(BlockingQueue q, int n, int iters) throws Exception { LoopHelpers.BarrierTimer timer = new LoopHelpers.BarrierTimer();