--- jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2014/12/18 18:13:06 1.11 +++ jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2016/12/31 19:25:33 1.14 @@ -4,8 +4,18 @@ * 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(); @@ -105,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 {