# | Line 118 | Line 118 | public class ConcurrentQueueLoops { | |
---|---|---|
118 | } | |
119 | ||
120 | static void oneRun(Class klass, int n) throws Exception { | |
121 | < | Queue<Integer> q = (Queue<Integer>)klass.newInstance(); |
121 | > | Queue<Integer> q = (Queue<Integer>) klass.newInstance(); |
122 | LoopHelpers.BarrierTimer timer = new LoopHelpers.BarrierTimer(); | |
123 | CyclicBarrier barrier = new CyclicBarrier(n + 1, timer); | |
124 | ArrayList<Future<Integer>> results = new ArrayList<Future<Integer>>(n); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |