Lines Matching refs:LinkedBlockingQueue
23 import java.util.concurrent.LinkedBlockingQueue;
34 // return new LinkedBlockingQueue();
40 // return new LinkedBlockingQueue(SIZE);
58 private LinkedBlockingQueue<Integer> populatedQueue(int n) {
59 LinkedBlockingQueue<Integer> q =
60 new LinkedBlockingQueue<Integer>(n);
75 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity());
76 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity());
84 new LinkedBlockingQueue(0);
94 new LinkedBlockingQueue(null);
105 new LinkedBlockingQueue(elements);
120 new LinkedBlockingQueue(elements);
132 LinkedBlockingQueue q = new LinkedBlockingQueue(Arrays.asList(ints));
141 LinkedBlockingQueue q = new LinkedBlockingQueue(2);
173 LinkedBlockingQueue q = new LinkedBlockingQueue(1);
182 LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
196 LinkedBlockingQueue q = populatedQueue(SIZE);
208 LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
223 LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE - 1);
242 LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
253 LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
266 final LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
303 final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
336 final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
362 LinkedBlockingQueue q = populatedQueue(SIZE);
405 LinkedBlockingQueue q = populatedQueue(SIZE);
416 LinkedBlockingQueue q = populatedQueue(SIZE);
427 LinkedBlockingQueue<Integer> q = populatedQueue(SIZE);
474 LinkedBlockingQueue q = populatedQueue(SIZE);
488 LinkedBlockingQueue q = populatedQueue(SIZE);
503 LinkedBlockingQueue q = populatedQueue(SIZE);
517 LinkedBlockingQueue q = new LinkedBlockingQueue();
530 LinkedBlockingQueue q = populatedQueue(SIZE);
542 LinkedBlockingQueue q = populatedQueue(SIZE);
558 LinkedBlockingQueue q = populatedQueue(SIZE);
559 LinkedBlockingQueue p = new LinkedBlockingQueue(SIZE);
572 LinkedBlockingQueue q = populatedQueue(SIZE);
573 LinkedBlockingQueue p = populatedQueue(SIZE);
592 LinkedBlockingQueue q = populatedQueue(SIZE);
593 LinkedBlockingQueue p = populatedQueue(i);
607 LinkedBlockingQueue q = populatedQueue(SIZE);
617 LinkedBlockingQueue<Integer> q = populatedQueue(SIZE);
629 LinkedBlockingQueue q = populatedQueue(SIZE);
640 LinkedBlockingQueue q = populatedQueue(SIZE);
659 assertIteratorExhausted(new LinkedBlockingQueue().iterator());
666 final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
685 final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
701 final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
716 LinkedBlockingQueue q = populatedQueue(SIZE);
727 final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
753 final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
795 LinkedBlockingQueue q = populatedQueue(SIZE);
819 final LinkedBlockingQueue q = populatedQueue(SIZE);
839 LinkedBlockingQueue q = new LinkedBlockingQueue();
859 new LinkedBlockingQueue<Object>(),
