Home
last modified time | relevance | path

Searched refs:poll (Results 1 – 25 of 61) sorted by relevance

123

/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/
DReferenceQueueTest.java73 assertNull(rq.poll()); in test_poll()
79 assertTrue("Remove failed.", ((Boolean) rq.poll().get()) in test_poll()
86 assertEquals("Remove failed.", obj, (rq.poll().get())); in test_poll()
92 assertNull("Remove failed.", rq.poll().get()); in test_poll()
97 assertNull(rq.poll()); in test_poll()
104 assertNull(rq.poll()); in test_poll()
124 assertNull(rq.poll()); in test_remove()
151 assertNull(rq.poll()); in test_remove()
159 assertNull("Queue should be empty. (poll)", rq.poll()); in test_removeJ()
198 assertNull(rq.poll()); in test_removeJ()
[all …]
DReferenceTest.java117 assertTrue("Not properly enqueued.", rq.poll().get() == obj); in test_enqueue()
121 && (rq.poll() == null)); in test_enqueue()
129 assertTrue("Not properly enqueued2.", rq.poll().get() == obj); in test_enqueue()
133 && (rq.poll() == null)); in test_enqueue()
138 assertNull("Not properly enqueued3.", rq.poll().get()); in test_enqueue()
142 && (rq.poll() == null)); in test_enqueue()
163 ref = queue.poll(); in test_get_WeakReference()
272 rq.poll(); in test_isEnqueued()
/libcore/luni/src/main/java/java/lang/ref/
DReferenceQueue.java47 public synchronized Reference<? extends T> poll() { in poll() method in ReferenceQueue
95 return poll(); in remove()
103 return poll(); in remove()
125 return poll(); in remove()
/libcore/luni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java167 public Future<V> poll() { in poll() method in ExecutorCompletionService
168 return completionQueue.poll(); in poll()
171 public Future<V> poll(long timeout, TimeUnit unit) in poll() method in ExecutorCompletionService
173 return completionQueue.poll(timeout, unit); in poll()
DCompletionService.java78 Future<V> poll(); in poll() method
94 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; in poll() method
DDelayQueue.java154 public E poll() { in poll() method in DelayQueue
162 return q.poll(); in poll()
186 return q.poll(); in take()
219 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in DelayQueue
234 return q.poll(); in poll()
318 q.poll(); in drainTo()
346 q.poll(); in drainTo()
DBlockingDeque.java502 E poll(); in poll() method
528 E poll(long timeout, TimeUnit unit) in poll() method
/libcore/jsr166-tests/src/test/java/jsr166/
DLinkedTransferQueueTest.java100 assertEquals(ints[i], q.poll()); in testConstructor5()
161 assertEquals(ints[i], q.poll()); in testAddAll5()
226 assertEquals(i, (int) q.poll()); in testPoll()
228 assertNull(q.poll()); in testPoll()
238 assertEquals(i, (int) q.poll(0, MILLISECONDS)); in testTimedPoll0()
240 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
251 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
255 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
271 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
277 q.poll(MEDIUM_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
DPriorityBlockingQueueTest.java116 assertEquals(ints[i], q.poll()); in testConstructor6()
131 assertEquals(ints[i], q.poll()); in testConstructor7()
238 assertEquals(ints[i], q.poll()); in testAddAll5()
336 assertEquals(i, q.poll()); in testPoll()
338 assertNull(q.poll()); in testPoll()
347 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0()
349 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
359 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
363 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
379 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
[all …]
DDelayQueueTest.java178 assertEquals(ints[i], q.poll()); in testConstructor6()
272 assertEquals(ints[i], q.poll()); in testAddAll5()
370 assertEquals(new PDelay(i), ((PDelay)q.poll())); in testPoll()
372 assertNull(q.poll()); in testPoll()
381 assertEquals(new PDelay(i), ((PDelay)q.poll(0, MILLISECONDS))); in testTimedPoll0()
383 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
393 assertEquals(new PDelay(i), ((PDelay)q.poll(LONG_DELAY_MS, MILLISECONDS))); in testTimedPoll()
397 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
412 assertEquals(new PDelay(i), ((PDelay)q.poll(SHORT_DELAY_MS, MILLISECONDS))); in testInterruptedTimedPoll()
417 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
DExecutorCompletionServiceTest.java121 assertNull(ecs.poll()); in testPoll1()
127 while ((f = ecs.poll()) == null) { in testPoll1()
146 assertNull(ecs.poll()); in testPoll2()
149 Future f = ecs.poll(SHORT_DELAY_MS, MILLISECONDS); in testPoll2()
176 assertNull(ecs.poll()); in testNewTaskForCallable()
208 assertNull(ecs.poll()); in testNewTaskForRunnable()
DArrayBlockingQueueTest.java118 assertEquals(ints[i], q.poll()); in testConstructor7()
229 assertEquals(ints[i], q.poll()); in testAddAll5()
390 assertEquals(i, q.poll()); in testPoll()
392 assertNull(q.poll()); in testPoll()
401 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0()
403 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
414 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
418 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
434 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
440 q.poll(MEDIUM_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
DLinkedBlockingQueueTest.java107 assertEquals(ints[i], q.poll()); in testConstructor6()
219 assertEquals(ints[i], q.poll()); in testAddAll5()
380 assertEquals(i, q.poll()); in testPoll()
382 assertNull(q.poll()); in testPoll()
391 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0()
393 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
403 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
407 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
423 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
429 q.poll(MEDIUM_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
DBlockingQueueTest.java194 assertSame(one, q.poll());
210 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPollWithOffer()
215 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
219 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
226 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
294 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
316 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
DPriorityQueueTest.java104 assertEquals(ints[i], q.poll()); in testConstructor6()
119 assertEquals(ints[i], q.poll()); in testConstructor7()
256 assertEquals(new Integer(i), q.poll()); in testAddAll5()
265 assertEquals(i, q.poll()); in testPoll()
267 assertNull(q.poll()); in testPoll()
277 assertEquals(i, q.poll()); in testPeek()
291 assertEquals(i, q.poll()); in testElement()
341 q.poll(); in testContains()
417 assertSame(o[i], q.poll()); in testToArray()
430 assertSame(ints[i], q.poll()); in testToArray2()
DConcurrentLinkedQueueTest.java85 assertEquals(ints[i], q.poll()); in testConstructor6()
220 assertEquals(ints[i], q.poll()); in testAddAll5()
229 assertEquals(i, q.poll()); in testPoll()
231 assertNull(q.poll()); in testPoll()
241 assertEquals(i, q.poll()); in testPeek()
255 assertEquals(i, q.poll()); in testElement()
305 q.poll(); in testContains()
380 assertSame(o[i], q.poll()); in testToArray()
392 assertSame(ints[i], q.poll()); in testToArray2()
DSynchronousQueueTest.java193 assertNull(q.poll()); in testPoll()
203 try { assertNull(q.poll(0, MILLISECONDS)); } in testTimedPoll0()
215 try { assertNull(q.poll(timeoutMillis(), MILLISECONDS)); } in testTimedPoll()
233 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPollWithOffer()
238 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
243 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
250 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
488 assertNull(q.poll());
490 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
DLinkedListTest.java60 assertEquals(ints[i], q.poll()); in testConstructor6()
143 assertEquals(ints[i], q.poll()); in testAddAll5()
180 assertEquals(i, q.poll()); in testPoll()
182 assertNull(q.poll()); in testPoll()
192 assertEquals(i, q.poll()); in testPeek()
206 assertEquals(i, q.poll()); in testElement()
256 q.poll(); in testContains()
331 assertSame(o[i], q.poll()); in testToArray()
343 assertSame(ints[i], q.poll()); in testToArray2()
DAbstractQueueTest.java25 public Integer poll() { return one; } in poll() method in AbstractQueueTest.Succeed
36 public Integer poll() { return null; } in poll() method in AbstractQueueTest.Fail
DLinkedBlockingDequeTest.java365 assertEquals(ints[i], q.poll()); in testConstructor6()
529 assertEquals(ints[i], q.poll()); in testAddAll5()
690 assertEquals(i, q.poll()); in testPoll()
692 assertNull(q.poll()); in testPoll()
701 assertEquals(i, q.poll(0, MILLISECONDS)); in testTimedPoll0()
703 assertNull(q.poll(0, MILLISECONDS)); in testTimedPoll0()
713 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
717 assertNull(q.poll(timeoutMillis(), MILLISECONDS)); in testTimedPoll()
733 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
739 q.poll(MEDIUM_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
[all …]
/libcore/luni/src/main/java/java/util/
DAbstractQueue.java84 E x = poll(); in remove()
118 while (poll() != null) in clear()
DWeakHashMap.java261 while (referenceQueue.poll() != null) {
294 poll(); in entrySet()
352 poll();
413 poll();
454 poll();
477 poll();
509 poll();
548 void poll() {
550 while ((toRemove = (Entry<K, V>) referenceQueue.poll()) != null) {
589 poll();
[all …]
DQueue.java169 E poll(); in poll() method
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
DPriorityQueueTest.java133 assertEquals(newArray[i], integerQueue.poll()); in test_iterator_remove()
274 assertEquals(array[i], integerQueue.poll()); in test_ConstructorLjava_util_Colleciton()
323 assertEquals(queue.poll(), constructedQueue.poll()); in test_ConstructorLjava_util_Colleciton_from_priorityqueue()
342 assertEquals(iter.next(), queue.poll()); in test_ConstructorLjava_util_Colleciton_from_sortedset()
363 assertEquals(array[i], objectQueue.poll()); in test_ConstructorLjava_util_PriorityQueue()
392 assertEquals(iter.next(), queue.poll()); in test_ConstructorLjava_util_SortedSet()
420 assertEquals(sortedArray[i], queue.poll()); in test_offerLjava_lang_Object()
423 assertNull(queue.poll()); in test_offerLjava_lang_Object()
473 assertEquals(array[i], stringQueue.poll()); in test_poll()
476 assertNull(stringQueue.poll()); in test_poll()
[all …]
/libcore/luni/src/test/java/libcore/java/util/
DOldPriorityQueueTest.java118 assertEquals(i, (int) q.poll()); in test_removeAt_siftUp()
120 assertNull(q.poll()); in test_removeAt_siftUp()

123