/libcore/ojluni/src/main/java/java/nio/file/ |
H A D | WatchService.java | 43 * {@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 D | Queue.java | 69 * <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 D | Deque.java | 122 * <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 D | ArrayDeque.java | 420 * This method differs from {@link #poll poll} only in that it throws an 442 public E poll() { method in class:ArrayDeque
|
H A D | PriorityQueue.java | 43 * 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 D | CompletionService.java | 107 Future<V> poll(); method in interface:CompletionService 123 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; method in interface:CompletionService
|
H A D | BlockingQueue.java | 80 * <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 D | ExecutorCompletionService.java | 198 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 D | BlockingDeque.java | 168 * <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 D | DelayQueue.java | 57 * 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 D | ConcurrentLinkedQueue.java | 136 * 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 D | LinkedBlockingQueue.java | 154 /** 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 D | PriorityBlockingQueue.java | 319 * 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 D | AbstractQueueTest.java | 36 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 D | ReferenceQueue.java | 148 public Reference<? extends T> poll() { method in class:ReferenceQueue
|
/libcore/ojluni/src/main/java/sun/nio/ch/ |
H A D | PollArrayWrapper.java | 114 int poll(int numfds, int offset, long timeout) { method in class:PollArrayWrapper
|
H A D | EPollPort.java | 42 // 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 D | ServerSocketChannelImpl.java | 52 // 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 D | SocketChannelImpl.java | 75 // 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 D | AbstractWatchService.java | 89 // 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 D | PollingWatchService.java | 40 * 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 D | LinuxWatchService.java | 341 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 D | AbstractQueueTest.java | 87 public E poll() { method in class:AbstractQueueTest.MockAbstractQueue
|
/libcore/luni/src/main/java/libcore/io/ |
H A D | IoBridge.java | 159 // 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 D | BlockGuardOs.java | 210 @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);
|