# | Line 26 | Line 26 | public class CancelledProducerConsumerLo | |
---|---|---|
26 | try { | |
27 | oneTest(i, iters); | |
28 | } | |
29 | < | catch(BrokenBarrierException bb) { |
29 | > | catch (BrokenBarrierException bb) { |
30 | // OK, ignore | |
31 | } | |
32 | Thread.sleep(100); | |
# | Line 87 | Line 87 | public class CancelledProducerConsumerLo | |
87 | System.out.print("LinkedBlockingQueue "); | |
88 | oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters); | |
89 | ||
90 | + | if (print) |
91 | + | System.out.print("LinkedTransferQueue "); |
92 | + | oneRun(new LinkedTransferQueue<Integer>(), pairs, iters); |
93 | ||
94 | if (print) | |
95 | System.out.print("SynchronousQueue "); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |