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