Searched defs:poll (Results 1 - 25 of 40) sorted by relevance

12

/libcore/ojluni/src/main/java/java/nio/file/
H A DWatchService.java43 * {@link #poll() poll} or {@link #take() take} methods to retrieve keys
93 * may not be detected by primitive implementations that periodically poll the
114 * #poll(long,TimeUnit) poll} methods waiting for a key to be queued then
139 WatchKey poll(); method in interface:WatchService
159 WatchKey poll(long timeout, TimeUnit unit) method in interface:WatchService
/libcore/ojluni/src/main/java/java/util/
H A DQueue.java69 * <td>{@link Queue#poll poll()}</td>
85 * {@link #poll()}. In a FIFO queue, all new elements are inserted at
98 * <p>The {@link #remove()} and {@link #poll()} methods remove and
103 * {@code poll()} methods differ only in their behavior when the
105 * while the {@code poll()} method returns {@code null}.
121 * used as a special return value by the {@code poll} method to
176 * from {@link #poll poll} only in that it throws an exception if this
190 E poll(); method in interface:Queue
[all...]
H A DDeque.java122 * <td>{@link java.util.Queue#poll poll()}</td>
432 * This method differs from {@link #poll poll} only in that it throws an
452 E poll(); method in interface:Deque
H A DArrayDeque.java420 * This method differs from {@link #poll poll} only in that it throws an
442 public E poll() { method in class:ArrayDeque
H A DPriorityQueue.java43 * broken arbitrarily. The queue retrieval operations {@code poll},
69 * ({@code offer}, {@code poll}, {@code remove()} and {@code add});
540 lastRetElt = forgetMeNot.poll();
586 public E poll() { method in class:PriorityQueue
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DCompletionService.java107 Future<V> poll(); method in interface:CompletionService
123 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; method in interface:CompletionService
H A DBlockingQueue.java80 * <td>{@link #poll poll()}</td>
82 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
97 * {@code poll} operations.
277 E poll(long timeout, TimeUnit unit) method in interface:BlockingQueue
H A DExecutorCompletionService.java198 public Future<V> poll() { method in class:ExecutorCompletionService
199 return completionQueue.poll();
202 public Future<V> poll(long timeout, TimeUnit unit) method in class:ExecutorCompletionService
204 return completionQueue.poll(timeout, unit);
H A DBlockingDeque.java168 * <td>{@link #poll() poll()}</td>
176 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
519 * This method differs from {@link #poll poll} only in that it
538 E poll(); method in interface:BlockingDeque
564 E poll(long timeout, TimeUnit unit) method in interface:BlockingDeque
H A DDelayQueue.java57 * past. If no delay has expired there is no head and {@code poll}
61 * removed using {@code take} or {@code poll}, they are otherwise
90 * poll(...), unless some other thread becomes leader in the
189 public E poll() { method in class:DelayQueue
196 : q.poll();
220 return q.poll();
253 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:DelayQueue
268 return q.poll();
297 * {@code poll}, if no expired elements are available in the queue,
352 q.poll();
[all...]
H A DConcurrentLinkedQueue.java136 * poll() that has lost its time slice.
163 * poll() and remove(Object) where the same element would appear
339 public E poll() { method in class:ConcurrentLinkedQueue
383 * This is yet another variant of poll/peek; here returning the
387 * of losing a race to a concurrent poll().
H A DLinkedBlockingQueue.java154 /** Lock held by take, poll, etc */
181 * Signals a waiting put. Called only from take/poll.
456 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:LinkedBlockingQueue
481 public E poll() { method in class:LinkedBlockingQueue
H A DPriorityBlockingQueue.java319 * Mechanics for poll(). Call only while holding lock.
532 public E poll() { method in class:PriorityBlockingQueue
555 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:PriorityBlockingQueue
/libcore/jsr166-tests/src/test/java/jsr166/
H A DAbstractQueueTest.java36 public Integer poll() { return one; } method in class:AbstractQueueTest.Succeed
47 public Integer poll() { return null; } method in class:AbstractQueueTest.Fail
83 * remove returns normally if poll succeeds
91 * remove throws NSEE if poll returns null
/libcore/ojluni/src/main/java/java/lang/ref/
H A DReferenceQueue.java148 public Reference<? extends T> poll() { method in class:ReferenceQueue
/libcore/ojluni/src/main/java/sun/nio/ch/
H A DPollArrayWrapper.java114 int poll(int numfds, int offset, long timeout) { method in class:PollArrayWrapper
H A DEPollPort.java42 // maximum number of events to poll at a time
60 // address of the poll array passed to epoll_wait
103 // allocate the poll array
187 * event is used to signal one consumer to re-poll when all events have
191 private Event poll() throws IOException { method in class:EPollPort.EventHandlerTask
242 // to ensure that some thread will poll when all events have
265 // poll for more.
268 ev = poll();
H A DServerSocketChannelImpl.java52 // fd value needed for dev/poll. This value will remain valid
314 * Translates native poll revent set into a ready operation set
352 int poll(int events, long timeout) throws IOException { method in class:ServerSocketChannelImpl
364 n = Net.poll(fd, events, timeout);
374 * Translates an interest operation set into a native poll event set
H A DSocketChannelImpl.java75 // fd value needed for dev/poll. This value will remain valid
788 // poll()/getsockopt() does not report
941 * Translates native poll revent ops into a ready operation ops
959 // No need to poll again in checkConnect,
995 int poll(int events, long timeout) throws IOException { method in class:SocketChannelImpl
1007 n = Net.poll(fd, events, timeout);
1017 * Translates an interest operation set into a native poll event set
/libcore/ojluni/src/main/java/sun/nio/fs/
H A DAbstractWatchService.java89 // re-queue in case there are other threads blocked in take/poll
96 public final WatchKey poll() { method in class:AbstractWatchService
98 WatchKey key = pendingKeys.poll();
104 public final WatchKey poll(long timeout, TimeUnit unit) method in class:AbstractWatchService
108 WatchKey key = pendingKeys.poll(timeout, unit);
156 // threads blocked in take/poll wakeup
H A DPollingWatchService.java40 * Simple WatchService implementation that uses periodic tasks to poll
52 // used to execute the periodic tasks that poll for changes
288 Runnable thunk = new Runnable() { public void run() { poll(); }};
315 synchronized void poll() { method in class:PollingWatchService.PollingWatchKey
344 // next poll
378 // entry in cache so update poll time
384 // then the key will be cancelled on the next poll
H A DLinuxWatchService.java341 nReady = poll(ifd, socketpair[0]);
490 private static native int poll(int fd1, int fd2) throws UnixException; method in class:LinuxWatchService
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
H A DAbstractQueueTest.java87 public E poll() { method in class:AbstractQueueTest.MockAbstractQueue
/libcore/luni/src/main/java/libcore/io/
H A DIoBridge.java159 // 3. loop using poll(2) to decide whether we're connected, whether we should keep
179 // 3. loop using poll(2).
254 int rc = Libcore.os.poll(pollFds, remainingTimeoutMs);
677 * passed. See poll(2) and @link{android.system.Os.Poll}.
679 * @throws SocketException if poll(2) fails.
682 public static void poll(FileDescriptor fd, int events, int timeout) method in class:IoBridge
689 int ret = android.system.Os.poll(pollFds, timeout);
H A DBlockGuardOs.java210 @Override public int poll(StructPollfd[] fds, int timeoutMs) throws ErrnoException { method in class:BlockGuardOs
212 // but 0 means "poll and return immediately", which shouldn't be subject to BlockGuard.
216 return os.poll(fds, timeoutMs);

Completed in 1303 milliseconds

12