--- jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2011/04/14 23:16:10 1.10 +++ jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2015/08/10 03:13:33 1.13 @@ -6,7 +6,6 @@ import java.util.concurrent.*; - public class TimeoutProducerConsumerLoops { static final int NCPUS = Runtime.getRuntime().availableProcessors(); static final ExecutorService pool = Executors.newCachedThreadPool(); @@ -51,8 +50,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); @@ -106,7 +104,6 @@ public class TimeoutProducerConsumerLoop if (print) System.out.print("ArrayBlockingQueue(fair) "); oneRun(new ArrayBlockingQueue(POOL_SIZE, true), n, iters/16); - } abstract static class Stage implements Runnable {