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

1234567

/openjdk7/jdk/src/share/classes/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
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DCompletionService.java109 Future<V> poll(); method in interface:CompletionService
125 Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException; method in interface:CompletionService
H A DExecutorCompletionService.java196 public Future<V> poll() { method in class:ExecutorCompletionService
197 return completionQueue.poll();
200 public Future<V> poll(long timeout, TimeUnit unit) method in class:ExecutorCompletionService
202 return completionQueue.poll(timeout, unit);
H A DBlockingQueue.java75 * <td>{@link #poll poll()}</td>
77 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
92 * <tt>poll</tt> operations.
277 E poll(long timeout, TimeUnit unit) method in interface:BlockingQueue
H A DBlockingDeque.java161 * <td>{@link #poll() poll()}</td>
169 * <td>{@link #poll(long, TimeUnit) poll(time, unit)}</td>
512 * This method differs from {@link #poll poll} only in that it
531 E poll(); method in interface:BlockingDeque
557 E poll(long timeout, TimeUnit unit) method in interface:BlockingDeque
H A DDelayQueue.java46 * past. If no delay has expired there is no head and <tt>poll</tt>
50 * removed using <tt>take</tt> or <tt>poll</tt>, they are otherwise
82 * poll(...), unless some other thread becomes leader in the
181 public E poll() { method in class:DelayQueue
189 return q.poll();
213 return q.poll();
245 public E poll(long timeout, TimeUnit unit) throws InterruptedException { method in class:DelayQueue
260 return q.poll();
288 * <tt>poll</tt>, if no expired elements are available in the queue,
334 c.add(q.poll());
[all...]
/openjdk7/jdk/src/share/classes/java/util/
H A DQueue.java65 * <td>{@link #poll poll()}</td>
81 * {@link #poll()}. In a FIFO queue, all new elements are inserted at
94 * <p>The {@link #remove()} and {@link #poll()} methods remove and
99 * <tt>poll()</tt> methods differ only in their behavior when the
101 * while the <tt>poll()</tt> method returns <tt>null</tt>.
117 * used as a special return value by the <tt>poll</tt> method to
185 * from {@link #poll poll} only in that it throws an exception if this
199 E poll(); method in interface:Queue
[all...]
H A DAbstractQueue.java44 * #poll poll}, and {@link #peek peek}, respectively, but throw
51 * Queue#peek}, {@link Queue#poll}, {@link Collection#size}, and
103 * from {@link #poll poll} only in that it throws an exception if this
106 * <p>This implementation returns the result of <tt>poll</tt>
113 E x = poll();
143 * <p>This implementation repeatedly invokes {@link #poll poll} until it
147 while (poll() !
[all...]
H A DDeque.java121 * <td>{@link java.util.Queue#poll poll()}</td>
434 * This method differs from {@link #poll poll} only in that it throws an
454 E poll(); method in interface:Deque
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DPollMemoryLeak.java58 q.poll(1, TimeUnit.NANOSECONDS);
/openjdk7/jdk/src/share/classes/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
/openjdk7/jdk/src/solaris/native/sun/nio/ch/
H A DPollArrayWrapper.c31 #include <poll.h>
53 int res = poll(fds, nfds, remaining);
82 RESTARTABLE (poll(a, numfds, timeout), err);
H A DSocketChannelImpl.c32 #include <poll.h>
64 result = poll(&poller, 1, block ? -1 : 0);
/openjdk7/jdk/src/share/classes/sun/swing/text/
H A DCompoundPrintable.java56 offset += printables.poll().getNumberOfPages();
/openjdk7/jdk/test/java/util/concurrent/DelayQueue/
H A DPollUnexpired.java27 * @summary Try to poll a DelayQueue with only unexpired elements
43 equal(q.poll(), null);
45 equal(q.poll(100, TimeUnit.MILLISECONDS), null);
H A DStress.java57 q.poll(10L, TimeUnit.SECONDS);
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DIteratorWeakConsistency.java67 q.poll();
68 q.poll();
69 q.poll();
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/istack/internal/
H A DPool.java74 T t = getQueue().poll();
/openjdk7/jdk/test/java/nio/file/WatchService/
H A DLotsOfEvents.java94 WatchKey key = watcher.poll(15, TimeUnit.SECONDS);
121 key = watcher.poll(2, TimeUnit.SECONDS);
166 WatchKey key = watcher.poll(15, TimeUnit.SECONDS);
184 key = watcher.poll(2, TimeUnit.SECONDS);
/openjdk7/jdk/test/java/lang/ref/
H A DBasic.java110 while ((r = q2.poll()) != null) {
125 while ((r = q.poll()) != null) {
/openjdk7/jdk/src/share/classes/sun/net/www/http/
H A DKeepAliveStreamCleaner.java56 // timeout for both socket and poll on the queue
100 while ((kace = poll()) == null) {
107 kace = poll();
/openjdk7/jdk/src/share/classes/sun/security/pkcs11/
H A DSessionManager.java122 Session session = objSessions.poll();
126 session = opSessions.poll();
135 Session session = opSessions.poll();
146 session = objSessions.poll();
241 Session poll() { method in class:SessionManager.Pool
/openjdk7/jdk/src/macosx/classes/sun/nio/ch/
H A DKQueueArrayWrapper.java176 while ((u = updateList.poll()) != null) {
198 int poll(long timeout) { method in class:KQueueArrayWrapper
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/org/jvnet/mimepull/
H A DWeakDataFile.java108 WeakDataFile weak = (WeakDataFile) refQueue.poll();
113 weak = (WeakDataFile) refQueue.poll();
/openjdk7/jdk/src/solaris/native/java/net/
H A Dnet_util_md.h36 #include <sys/poll.h>
76 #define NET_Poll poll

Completed in 1431 milliseconds

1234567