Searched refs:poll (Results 1 - 25 of 42) sorted by relevance

12

/libcore/luni/src/main/java/java/util/concurrent/
H A DCompletionService.java80 Future<V> poll(); method in interface:CompletionService
96 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; method in interface:CompletionService
H A DExecutorCompletionService.java167 public Future<V> poll() { method in class:ExecutorCompletionService
168 return completionQueue.poll();
171 public Future<V> poll(long timeout, TimeUnit unit) method in class:ExecutorCompletionService
173 return completionQueue.poll(timeout, unit);
H A DBlockingQueue.java50 * <td>{@link #poll poll()}</td>
52 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
67 * <tt>poll</tt> operations.
247 E poll(long timeout, TimeUnit unit) method in interface:BlockingQueue
H A DBlockingDeque.java132 * <td>{@link #poll() poll()}</td>
140 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
483 * This method differs from {@link #poll poll} only in that it
502 E poll(); method in interface:BlockingDeque
528 E poll(long timeout, TimeUnit unit) method in interface:BlockingDeque
H A DDelayQueue.java23 * past. If no delay has expired there is no head and <tt>poll</tt>
27 * removed using <tt>take</tt> or <tt>poll</tt>, they are otherwise
57 * poll(...), unless some other thread becomes leader in the
156 public E poll() { method in class:DelayQueue
164 return q.poll();
188 return q.poll();
220 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:DelayQueue
235 return q.poll();
263 * <tt>poll</tt>, if no expired elements are available in the queue,
318 q.poll();
[all...]
H A DAbstractExecutorService.java141 Future<T> f = ecs.poll();
151 f = ecs.poll(nanos, TimeUnit.NANOSECONDS);
H A DLinkedTransferQueue.java247 * of offer, put, poll, take, or transfer (each possibly with
271 * poll/offer, (argument "how" is NOW) return.
346 * calls to poll repeatedly time out but never otherwise fall off
555 private static final int NOW = 0; // for untimed poll, tryTransfer
558 private static final int TIMED = 3; // for timed poll, tryTransfer
1059 * {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
1073 * {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
1092 * {@link #take} or timed {@link #poll(lon
1117 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:LinkedTransferQueue
1124 public E poll() { method in class:LinkedTransferQueue
[all...]
H A DSynchronousQueue.java28 * <tt>poll()</tt> will return <tt>null</tt>. For purposes of other
399 * SynchronousQueue.{poll/offer} don't check interrupts
910 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:SynchronousQueue
924 public E poll() { method in class:SynchronousQueue
1086 for (E e; (e = poll()) != null;) {
1105 for (E e; n < maxElements && (e = poll()) != null;) {
H A DLinkedBlockingQueue.java123 /** Lock held by take, poll, etc */
150 * Signals a waiting put. Called only from take/poll.
427 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:LinkedBlockingQueue
452 public E poll() { method in class:LinkedBlockingQueue
H A DArrayBlockingQueue.java65 /** items index for next take, poll, peek or remove */
357 public E poll() { method in class:ArrayBlockingQueue
379 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:ArrayBlockingQueue
H A DLinkedBlockingDeque.java632 * This method differs from {@link #poll poll} only in that it throws an
644 public E poll() { method in class:LinkedBlockingDeque
652 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:LinkedBlockingDeque
/libcore/luni/src/main/java/java/util/
H A DQueue.java40 * <td>{@link #poll poll()}</td>
56 * {@link #poll()}. In a FIFO queue, all new elements are inserted at
69 * <p>The {@link #remove()} and {@link #poll()} methods remove and
74 * <tt>poll()</tt> methods differ only in their behavior when the
76 * while the <tt>poll()</tt> method returns <tt>null</tt>.
92 * used as a special return value by the <tt>poll</tt> method to
155 * from {@link #poll poll} only in that it throws an exception if this
169 E poll(); method in interface:Queue
[all...]
H A DAbstractQueue.java19 * #poll poll}, and {@link #peek peek}, respectively, but throw
26 * Queue#peek}, {@link Queue#poll}, {@link Collection#size}, and
74 * from {@link #poll poll} only in that it throws an exception if this
77 * <p>This implementation returns the result of <tt>poll</tt>
84 E x = poll();
114 * <p>This implementation repeatedly invokes {@link #poll poll} until it
118 while (poll() !
[all...]
H A DDeque.java96 * <td>{@link java.util.Queue#poll poll()}</td>
401 * This method differs from {@link #poll poll} only in that it throws an
421 E poll(); method in interface:Deque
H A DWeakHashMap.java174 // cannot poll() as that would change the expectedModCount
260 while (referenceQueue.poll() != null) {
293 poll();
351 poll();
432 poll();
473 poll();
496 poll();
528 poll();
567 void poll() { method in class:WeakHashMap
569 while ((toRemove = (Entry<K, V>) referenceQueue.poll()) !
[all...]
H A DPriorityQueue.java202 public E poll() { method in class:PriorityQueue
/libcore/luni/src/main/java/java/lang/ref/
H A DReferenceQueue.java46 public synchronized Reference<? extends T> poll() { method in class:ReferenceQueue
96 return poll();
104 return poll();
126 return poll();
/libcore/luni/src/test/java/tests/api/java/lang/ref/
H A DReferenceQueueTest.java61 * java.lang.ref.ReferenceQueue#poll()
73 assertNull(rq.poll());
79 assertNull("Remove failed.", rq.poll().get());
85 assertEquals("Remove failed.", obj, (rq.poll().get()));
91 assertTrue("Remove failed.", ((Boolean) rq.poll().get())
96 assertNull(rq.poll());
103 assertNull(rq.poll());
123 assertNull(rq.poll());
150 assertNull(rq.poll());
158 assertNull("Queue should be empty. (poll)", r
[all...]
H A DReferenceTest.java117 assertTrue("Not properly enqueued.", rq.poll().get() == obj);
121 && (rq.poll() == null));
129 assertTrue("Not properly enqueued2.", rq.poll().get() == obj);
133 && (rq.poll() == null));
138 assertNull("Not properly enqueued3.", rq.poll().get());
142 && (rq.poll() == null));
163 ref = queue.poll();
272 rq.poll();
H A DSoftReferenceTest.java129 ref = rq.poll();
/libcore/luni/src/main/native/
H A Dlibcore_net_RawSocket.cpp37 #include <poll.h>
170 int retval = poll(fds, 1, timeout_millis);
/libcore/luni/src/main/java/java/lang/
H A DProcessManager.java71 while ((reference = referenceQueue.poll()) != null) {
328 public ProcessReference poll() { method in class:ProcessManager.ProcessReferenceQueue
330 Object reference = super.poll();
/libcore/support/src/test/java/tests/io/
H A DMockOs.java58 InvocationHandler handler = getHandlers(method.getName()).poll();
/libcore/luni/src/main/java/libcore/io/
H A DBlockGuardOs.java113 @Override public int poll(StructPollfd[] fds, int timeoutMs) throws ErrnoException { method in class:BlockGuardOs
115 // but 0 means "poll and return immediately", which shouldn't be subject to BlockGuard.
119 return os.poll(fds, timeoutMs);
/libcore/luni/src/test/java/tests/api/java/util/
H A DAbstractQueueTest.java87 public E poll() { method in class:AbstractQueueTest.MockAbstractQueue

Completed in 510 milliseconds

12