| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ExecutorCompletionServiceTest.java | 99 Future f = ecs.take(); in testTake()
113 Future f2 = ecs.take(); in testTake2()
182 Future f2 = ecs.take(); in testNewTaskForCallable()
213 Future f2 = ecs.take(); in testNewTaskForRunnable()
|
| D | PriorityBlockingQueueTest.java | 294 q.take(); in testPutWithTake()
319 assertEquals(i, q.take()); in testTake()
332 assertEquals(i, q.take()); in testBlockingTake()
337 q.take(); in testBlockingTake()
344 q.take(); in testBlockingTake()
549 assertSame(o[i], q.take()); in testToArray()
562 assertSame(ints[i], q.take()); in testToArray2()
|
| D | LinkedBlockingQueueTest.java | 325 assertEquals(0, q.take()); in testPutWithTake()
366 assertEquals(i, q.take()); in testTake()
379 assertEquals(i, q.take()); in testBlockingTake()
384 q.take(); in testBlockingTake()
391 q.take(); in testBlockingTake()
523 assertNotNull(q.take()); in testRemoveElementAndAdd()
650 assertEquals(it.next(), q.take()); in testIterator()
744 assertSame(one, q.take()); in testOfferInExecutor()
|
| D | LinkedTransferQueueTest.java | 210 assertEquals(i, (int) q.take()); in testTake()
223 assertEquals(i, q.take()); in testBlockingTake()
228 q.take(); in testBlockingTake()
235 q.take(); in testBlockingTake()
393 assertSame(q.take(), three); in testRemoveElementAndAdd()
523 assertEquals(it.next(), q.take()); in testIterator()
618 assertSame(one, q.take()); in testOfferInExecutor()
879 assertSame(four, q.take()); in testTransfer5()
947 assertSame(q.take(), hotPotato);
|
| D | DelayQueueTest.java | 349 assertEquals(new PDelay(i), q.take()); in testTake()
362 assertEquals(new PDelay(i), ((PDelay)q.take())); in testBlockingTake()
367 q.take(); in testBlockingTake()
374 q.take(); in testBlockingTake()
593 assertSame(o[i], q.take()); in testToArray()
703 NanoDelay e = q.take(); in testDelay()
|
| D | ArrayBlockingQueueTest.java | 335 assertEquals(0, q.take()); in testPutWithTake()
376 assertEquals(i, q.take()); in testTake()
389 assertEquals(i, q.take()); in testBlockingTake()
394 q.take(); in testBlockingTake()
401 q.take(); in testBlockingTake()
714 assertEquals(it.next(), q.take()); in testIterator()
811 assertSame(one, q.take()); in testOfferInExecutor()
|
| D | BlockingQueueTest.java | 267 q.take();
289 q.take();
|
| D | LinkedBlockingDequeTest.java | 633 assertEquals(0, q.take()); in testPutWithTake()
674 assertEquals(i, q.take()); in testTake()
687 assertEquals(i, q.take()); in testBlockingTake()
692 q.take(); in testBlockingTake()
699 q.take(); in testBlockingTake()
863 assertEquals(capacity - 1, q.take()); in testPutFirstWithTake()
1212 assertEquals(0, q.take());
1540 assertEquals(it.next(), q.take());
1698 assertSame(one, q.take());
|
| D | SynchronousQueueTest.java | 178 try { assertSame(one, q.take()); } in testPutWithTake()
495 assertSame(one, q.take());
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | AbstractWatchService.java | 114 public final WatchKey take() in take() method in AbstractWatchService
118 WatchKey key = pendingKeys.take(); in take()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 194 public Future<V> take() throws InterruptedException { in take() method in ExecutorCompletionService
195 return completionQueue.take(); in take()
|
| D | ArrayBlockingQueue.java | 382 public E take() throws InterruptedException { in take() method in ArrayBlockingQueue
676 int take = takeIndex; in drainTo() local
681 E x = (E) items[take]; in drainTo()
683 items[take] = null; in drainTo()
684 if (++take == items.length) take = 0; in drainTo()
692 takeIndex = take; in drainTo()
696 else if (i > take) in drainTo()
|
| D | CompletionService.java | 98 Future<V> take() throws InterruptedException; in take() method
|
| D | BlockingQueue.java | 263 E take() throws InterruptedException; in take() method
|
| D | BlockingDeque.java | 550 E take() throws InterruptedException; in take() method
|
| D | AbstractExecutorService.java | 194 f = ecs.take(); in doInvokeAny()
|
| D | DelayQueue.java | 209 public E take() throws InterruptedException { in take() method in DelayQueue
|
| /libcore/ojluni/src/main/java/java/nio/file/ |
| D | WatchService.java | 173 WatchKey take() throws InterruptedException; in take() method
|
| /libcore/luni/src/test/java/tests/security/ |
| D | SecureRandomTest.java | 93 ecs.take().get(); in testSecureRandomThreadSafety()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | EPollPort.java | 262 ev = queue.take(); in run()
|
| /libcore/tools/testmapping/ |
| D | README | 25 The scripts take no options. There are some constants at the start you can
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | LinkedBlockingQueue.java | 101 public E take() throws java.lang.InterruptedException { in take() method in LinkedBlockingQueue
|
| D | PriorityBlockingQueue.java | 111 public E take() throws java.lang.InterruptedException { in take() method in PriorityBlockingQueue
|
| D | LinkedBlockingDeque.java | 193 public E take() throws java.lang.InterruptedException { in take() method in LinkedBlockingDeque
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | AsynchronousFileChannelTest.java | 677 assertSame(serviceThread.get(), observedThreads.take()); in testCustomExecutor()
681 assertSame(serviceThread.get(), observedThreads.take()); in testCustomExecutor()
|