Searched defs:take (Results 1 - 14 of 14) sorted by relevance

/libcore/ojluni/src/main/java/java/nio/file/
H A DWatchService.java43 * {@link #poll() poll} or {@link #take() take} methods to retrieve keys
113 * <p> If a thread is currently blocked in the {@link #take take} or {@link
173 WatchKey take() throws InterruptedException; method in interface:WatchService
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DCompletionService.java41 * {@code submit} tasks for execution. Consumers {@code take}
59 * actions following a successful return from the corresponding {@code take()}.
98 Future<V> take() throws InterruptedException; method in interface:CompletionService
H A DBlockingQueue.java81 * <td>{@link #take take()}</td>
152 * while (true) { consume(queue.take()); }
263 E take() throws InterruptedException; method in interface:BlockingQueue
H A DExecutorCompletionService.java41 * upon completion, placed on a queue accessible using {@code take}.
65 * Result r = ecs.take().get();
89 * Result r = ecs.take().get();
194 public Future<V> take() throws InterruptedException { method in class:ExecutorCompletionService
195 return completionQueue.take();
H A DBlockingDeque.java172 * <td>{@link #take() take()}</td>
550 E take() throws InterruptedException; method in interface:BlockingDeque
H A DDelayQueue.java61 * removed using {@code take} or {@code poll}, they are otherwise
89 * signal some other thread before returning from take() or
209 public E take() throws InterruptedException { method in class:DelayQueue
H A DLinkedBlockingQueue.java91 * used. When a put notices that it has enabled at least one take,
154 /** Lock held by take, poll, etc */
167 * Signals a waiting take. Called only from put/offer (which do not
181 * Signals a waiting put. Called only from take/poll.
333 // Note: convention in all put/take/etc is to preset local var
434 public E take() throws InterruptedException { method in class:LinkedBlockingQueue
760 * still have it to return even if lost race with a take etc.
H A DPriorityBlockingQueue.java542 public E take() throws InterruptedException { method in class:PriorityBlockingQueue
H A DArrayBlockingQueue.java67 * will result in the operation blocking; attempts to {@code take} an
99 /** items index for next take, poll, peek or remove */
161 * Extracts element at current take position, advances, and signals.
382 public E take() throws InterruptedException { method in class:ArrayBlockingQueue
676 int take = takeIndex;
681 E x = (E) items[take];
683 items[take] = null;
684 if (++take == items.length) take = 0;
692 takeIndex = take;
[all...]
H A DLinkedBlockingDeque.java679 public E take() throws InterruptedException { method in class:LinkedBlockingDeque
H A DLinkedTransferQueue.java225 * (We also take similar care to wipe out possibly garbage
278 * of offer, put, poll, take, or transfer (each possibly with
378 * the list because of an untimed call to take at the front of the
586 private static final int SYNC = 2; // for transfer, take
592 * @param e the item or null for take
593 * @param haveData true if this is a put, else a take
1297 * {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
1311 * {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
1330 * {@link #take} or timed {@link #poll(long,TimeUnit) poll}),
1347 public E take() throw method in class:LinkedTransferQueue
[all...]
H A DScheduledThreadPoolExecutor.java888 * signal some other thread before returning from take() or
1085 * Performs common bookkeeping for poll and take: Replaces
1113 public RunnableScheduledFuture<?> take() throws InterruptedException { method in class:ScheduledThreadPoolExecutor.DelayedWorkQueue
H A DSynchronousQueue.java107 * or "requests" -- slots representing take operations, or is
116 * take. These are unified into a single method because in dual
117 * data structures, the put and take operations are symmetrical,
174 * Performs a put or take.
532 * from non-null to null (for put) or vice versa (for take).
642 /* Basic algorithm is to loop trying to take either of
919 public E take() throws InterruptedException { method in class:SynchronousQueue
/libcore/ojluni/src/main/java/sun/nio/fs/
H A DAbstractWatchService.java89 // re-queue in case there are other threads blocked in take/poll
114 public final WatchKey take() method in class:AbstractWatchService
118 WatchKey key = pendingKeys.take();
156 // threads blocked in take/poll wakeup

Completed in 37 milliseconds