--- jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2015/01/15 18:34:19 1.12 +++ jsr166/src/test/loops/TimeoutProducerConsumerLoops.java 2016/12/31 21:34:47 1.15 @@ -4,7 +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(); @@ -104,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 { @@ -214,8 +224,8 @@ public class TimeoutProducerConsumerLoop static final class LTQasSQ extends LinkedTransferQueue { LTQasSQ() { super(); } public void put(T x) { - try { super.transfer(x); - } catch (InterruptedException ex) { throw new Error(); } + try { super.transfer(x); } + catch (InterruptedException ex) { throw new Error(ex); } } public boolean offer(T x, long timeout, TimeUnit unit) {