/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 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 D | CompletionService.java | 41 * {@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 D | BlockingQueue.java | 81 * <td>{@link #take take()}</td> 152 * while (true) { consume(queue.take()); } 263 E take() throws InterruptedException; method in interface:BlockingQueue
|
H A D | ExecutorCompletionService.java | 41 * 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 D | BlockingDeque.java | 172 * <td>{@link #take() take()}</td> 550 E take() throws InterruptedException; method in interface:BlockingDeque
|
H A D | DelayQueue.java | 61 * 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 D | LinkedBlockingQueue.java | 91 * 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 D | PriorityBlockingQueue.java | 542 public E take() throws InterruptedException { method in class:PriorityBlockingQueue
|
H A D | ArrayBlockingQueue.java | 67 * 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 D | LinkedBlockingDeque.java | 679 public E take() throws InterruptedException { method in class:LinkedBlockingDeque
|
H A D | LinkedTransferQueue.java | 225 * (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 D | ScheduledThreadPoolExecutor.java | 888 * 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 D | SynchronousQueue.java | 107 * 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 D | AbstractWatchService.java | 89 // 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
|