Lines Matching refs:mQueue
30 private ConditionPriorityBlockingQueue<Integer> mQueue;
38 mQueue = new ConditionPriorityBlockingQueue<Integer>(new IntCompare());
45 assertNull(mQueue.poll());
53 mQueue.add(one);
54 assertEquals(one, mQueue.take());
55 assertNull(mQueue.poll());
65 mQueue.add(two);
66 mQueue.add(one);
67 assertEquals(one, mQueue.take());
68 assertEquals(two, mQueue.take());
69 assertNull(mQueue.poll());
94 mQueue.add(one);
95 mQueue.add(two);
96 assertEquals(one, mQueue.take());
97 assertEquals(two, mQueue.take());
98 assertNull(mQueue.poll());
113 mQueue.add(one);
118 assertEquals(one, mQueue.take());
119 assertNull(mQueue.poll());
129 mQueue.add(two);
137 mQueue.add(one);
142 assertEquals(one, mQueue.take(new OneMatcher()));
143 assertNull(mQueue.poll(new OneMatcher()));
144 assertEquals(two, mQueue.poll());
158 mQueue.take(new OneMatcher());
170 mQueue.take(new OneMatcher());
185 mQueue.add(one);
197 mQueue.add(second_one);
207 assertNull(mQueue.poll());
214 assertNull(mQueue.poll(new OneMatcher()));
222 assertNull(mQueue.poll(100, TimeUnit.MILLISECONDS, new OneMatcher()));
232 mQueue.add(one);
233 mQueue.add(two);
234 assertEquals(one, mQueue.poll(new OneMatcher()));
235 assertNull(mQueue.poll(new OneMatcher()));
245 mQueue.add(one);
246 mQueue.add(two);
247 assertEquals(one, mQueue.poll(100, TimeUnit.MILLISECONDS, new OneMatcher()));
248 assertNull(mQueue.poll(100, TimeUnit.MILLISECONDS, new OneMatcher()));
273 mQueue.add(two);
274 mQueue.add(one);
275 assertEquals(one, mQueue.poll(new OneMatcher()));
276 assertNull(mQueue.poll(new OneMatcher()));
