Lines Matching refs:counter
46 AtomicInteger counter = new AtomicInteger();
47 queue.add(incrementingCallback(counter, 1));
48 queue.add(incrementingCallback(counter, 2));
49 queue.add(incrementingCallback(counter, 3));
50 queue.add(incrementingCallback(counter, 4));
51 assertEquals(0, counter.get());
53 assertEquals(4, counter.get());
61 AtomicInteger counter = new AtomicInteger();
62 queue.add(incrementingCallback(counter, 1));
64 queue.add(incrementingCallback(counter, 2));
66 queue.add(incrementingCallback(counter, 3));
68 queue.add(incrementingCallback(counter, 4));
70 assertEquals(0, counter.get());
72 assertEquals(4, counter.get());
82 AtomicInteger counter = new AtomicInteger();
83 queue.add(incrementingCallback(counter, 1));
84 queue.add(incrementingCallback(counter, 2));
85 queue.add(incrementingCallback(counter, 3));
86 queue.add(incrementingCallback(counter, 4));
88 assertEquals(0, counter.get());
91 assertEquals(4, counter.get());
104 AtomicInteger counter = new AtomicInteger();
105 queue.add(incrementingCallback(counter, 1));
107 queue.add(incrementingCallback(counter, 2));
109 queue.add(incrementingCallback(counter, 3));
111 queue.add(incrementingCallback(counter, 4));
114 assertEquals(0, counter.get());
117 assertEquals(4, counter.get());
123 private Callback<Object> incrementingCallback(final AtomicInteger counter, final int expected) {
126 assertEquals(expected, counter.incrementAndGet());