--- jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2014/12/18 18:13:06 1.9 +++ jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2016/12/31 19:40:49 1.11 @@ -4,8 +4,16 @@ * http://creativecommons.org/publicdomain/zero/1.0/ */ -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.PriorityBlockingQueue; +import java.util.concurrent.SynchronousQueue; public class SingleProducerMultipleConsumerLoops { static final int NCPUS = Runtime.getRuntime().availableProcessors(); @@ -127,7 +135,6 @@ public class SingleProducerMultipleConsu if (print) System.out.print("ArrayBlockingQueue(fair)"); oneRun(new ArrayBlockingQueue(POOL_SIZE, true), n, fairIters); - } abstract static class Stage implements Runnable { @@ -169,7 +176,6 @@ public class SingleProducerMultipleConsu static class Consumer extends Stage { Consumer(BlockingQueue q, CyclicBarrier b, int iters) { super(q, b, iters); - } public void run() {