Lines Matching defs:elements
94 int elements = drain(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS, interruptibly);
95 assertEquals(100, elements);
138 // asking to drain zero elements
163 int elements = Queues.drain(q, buf, -1, Long.MAX_VALUE, TimeUnit.NANOSECONDS);
164 assertEquals(elements, 0);
203 int elements =
205 // so when this drains all elements, we know the thread has also been interrupted in between
207 assertEquals(100, elements);
279 final int elements;
281 Producer(BlockingQueue<Object> q, int elements) {
283 this.elements = elements;
288 for (int i = 0; i < elements; i++) {