--- jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2015/08/10 03:13:33 1.10 +++ jsr166/src/test/loops/SingleProducerMultipleConsumerLoops.java 2016/12/31 21:34:47 1.12 @@ -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(); @@ -208,8 +216,8 @@ public class SingleProducerMultipleConsu 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); } } } @@ -220,10 +228,8 @@ public class SingleProducerMultipleConsu if ((++calls & 1) == 0) super.put(x); else { - try { super.transfer(x); - } catch (InterruptedException ex) { - throw new Error(); - } + try { super.transfer(x); } + catch (InterruptedException ex) { throw new Error(ex); } } } }