# | Line 127 | Line 127 | public class SingleProducerMultipleConsu | |
---|---|---|
127 | if (print) | |
128 | System.out.print("ArrayBlockingQueue(fair)"); | |
129 | oneRun(new ArrayBlockingQueue<Integer>(POOL_SIZE, true), n, fairIters); | |
130 | – | |
130 | } | |
131 | ||
132 | abstract static class Stage implements Runnable { | |
# | Line 169 | Line 168 | public class SingleProducerMultipleConsu | |
168 | static class Consumer extends Stage { | |
169 | Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { | |
170 | super(q, b, iters); | |
172 | – | |
171 | } | |
172 | ||
173 | public void run() { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |