Lines Matching defs:ArrayBlockingQueue
18 import java.util.concurrent.ArrayBlockingQueue;
31 private ArrayBlockingQueue<Integer> populatedQueue(int n) {
32 ArrayBlockingQueue<Integer> q = new ArrayBlockingQueue<Integer>(n);
46 assertEquals(SIZE, new ArrayBlockingQueue(SIZE).remainingCapacity());
54 new ArrayBlockingQueue(0);
64 new ArrayBlockingQueue(1, true, null);
75 new ArrayBlockingQueue(SIZE, false, elements);
89 new ArrayBlockingQueue(SIZE, false, Arrays.asList(ints));
103 new ArrayBlockingQueue(SIZE - 1, false, elements);
116 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, true, elements);
125 ArrayBlockingQueue q = new ArrayBlockingQueue(2);
140 ArrayBlockingQueue q = populatedQueue(SIZE);
157 ArrayBlockingQueue q = new ArrayBlockingQueue(1);
167 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
182 ArrayBlockingQueue q = populatedQueue(SIZE);
194 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
208 ArrayBlockingQueue q = new ArrayBlockingQueue(1);
225 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
236 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
249 final ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
286 final ArrayBlockingQueue q = new ArrayBlockingQueue(capacity);
319 final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
345 ArrayBlockingQueue q = populatedQueue(SIZE);
355 final ArrayBlockingQueue q = populatedQueue(SIZE);
388 ArrayBlockingQueue q = populatedQueue(SIZE);
399 ArrayBlockingQueue q = populatedQueue(SIZE);
411 ArrayBlockingQueue q = populatedQueue(SIZE);
458 ArrayBlockingQueue q = populatedQueue(SIZE);
472 ArrayBlockingQueue q = populatedQueue(SIZE);
487 ArrayBlockingQueue q = populatedQueue(SIZE);
501 ArrayBlockingQueue q = populatedQueue(SIZE);
513 ArrayBlockingQueue q = populatedQueue(SIZE);
529 ArrayBlockingQueue q = populatedQueue(SIZE);
530 ArrayBlockingQueue p = new ArrayBlockingQueue(SIZE);
543 ArrayBlockingQueue q = populatedQueue(SIZE);
544 ArrayBlockingQueue p = populatedQueue(SIZE);
563 ArrayBlockingQueue q = populatedQueue(SIZE);
564 ArrayBlockingQueue p = populatedQueue(i);
574 void checkToArray(ArrayBlockingQueue q) {
590 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
608 void checkToArray2(ArrayBlockingQueue q) {
644 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
666 ArrayBlockingQueue q = populatedQueue(SIZE);
677 ArrayBlockingQueue q = populatedQueue(SIZE);
688 final ArrayBlockingQueue q = new ArrayBlockingQueue(3);
707 final ArrayBlockingQueue q = new ArrayBlockingQueue(3);
725 final ArrayBlockingQueue q = new ArrayBlockingQueue(3);
740 ArrayBlockingQueue q = populatedQueue(SIZE);
751 final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
778 final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
820 ArrayBlockingQueue q = populatedQueue(SIZE);
844 final ArrayBlockingQueue q = populatedQueue(SIZE);
864 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE*2);
