--- jsr166/src/test/loops/MultipleProducersSingleConsumerLoops.java 2014/12/18 18:13:06 1.9 +++ jsr166/src/test/loops/MultipleProducersSingleConsumerLoops.java 2016/12/31 19:54:17 1.14 @@ -4,13 +4,20 @@ * http://creativecommons.org/publicdomain/zero/1.0/ */ -import java.util.*; -import java.util.concurrent.*; -//import jsr166y.*; +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.CyclicBarrier; +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; public class MultipleProducersSingleConsumerLoops { static final int NCPUS = Runtime.getRuntime().availableProcessors(); - static final Random rng = new Random(); static final ExecutorService pool = Executors.newCachedThreadPool(); static boolean print = false; static int producerSum; @@ -120,7 +127,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) "); @@ -145,8 +151,6 @@ public class MultipleProducersSingleCons if (print) System.out.print("ArrayBlockingQueue(fair)"); oneRun(new ArrayBlockingQueue(POOL_SIZE, true), n, fairIters); - - } abstract static class Stage implements Runnable { @@ -229,7 +233,6 @@ public class MultipleProducersSingleCons } - static void oneRun(BlockingQueue q, int n, int iters) throws Exception { LoopHelpers.BarrierTimer timer = new LoopHelpers.BarrierTimer();