--- jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2010/09/27 19:15:16 1.8 +++ jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2016/12/31 19:25:33 1.14 @@ -1,11 +1,21 @@ /* * 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.*; - +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.CyclicBarrier; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.LinkedBlockingDeque; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.LinkedTransferQueue; +import java.util.concurrent.Phaser; +import java.util.concurrent.PriorityBlockingQueue; +import java.util.concurrent.SynchronousQueue; +import java.util.concurrent.TimeUnit; public class TimeoutProducerConsumerLoops { static final int NCPUS = Runtime.getRuntime().availableProcessors(); @@ -51,8 +61,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 +73,7 @@ public class TimeoutProducerConsumerLoop i = k; } pool.shutdown(); - } + } static void oneTest(int n, int iters) throws Exception { if (print) @@ -106,7 +115,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 {