| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ExecutorCompletionServiceTest.java | 113 Future f = cs.take(); in testTake()
124 Future f2 = cs.take(); in testTake2()
186 assertSame(TEST_STRING, cs.take().get()); in testPollReturnsNull()
205 if (cs.take().get() == TEST_STRING) in testTaskAssortment()
242 Future f2 = cs.take(); in testNewTaskForCallable()
272 Future f2 = cs.take(); in testNewTaskForRunnable()
|
| D | ExecutorCompletionService9Test.java | 67 Integer r = cs.take().get(); in solveAll()
85 Integer r = cs.take().get(); in solveAny()
|
| D | PriorityBlockingQueueTest.java | 327 q.take(); in testPutWithTake()
352 assertEquals(i, q.take()); in testTake()
365 assertEquals(i, q.take()); in testBlockingTake()
370 q.take(); in testBlockingTake()
377 q.take(); in testBlockingTake()
582 assertSame(o[i], q.take()); in testToArray()
595 assertSame(ints[i], q.take()); in testToArray2()
|
| D | LinkedBlockingQueueTest.java | 355 assertEquals(0, q.take()); in testPutWithTake()
396 assertEquals(i, q.take()); in testTake()
409 assertEquals(i, q.take()); in testBlockingTake()
414 q.take(); in testBlockingTake()
421 q.take(); in testBlockingTake()
553 assertNotNull(q.take()); in testRemoveElementAndAdd()
680 assertEquals(it.next(), q.take()); in testIterator()
774 assertSame(one, q.take()); in testOfferInExecutor()
|
| D | LinkedTransferQueueTest.java | 228 assertEquals(i, (int) q.take()); in testTake()
241 assertEquals(i, q.take()); in testBlockingTake()
246 q.take(); in testBlockingTake()
253 q.take(); in testBlockingTake()
411 assertSame(q.take(), three); in testRemoveElementAndAdd()
541 assertEquals(it.next(), q.take()); in testIterator()
635 assertSame(one, q.take()); in testOfferInExecutor()
893 assertSame(four, q.take()); in testTransfer5()
961 assertSame(q.take(), hotPotato);
|
| D | DelayQueueTest.java | 357 assertEquals(new PDelay(i), q.take()); in testTake()
370 assertEquals(new PDelay(i), ((PDelay)q.take())); in testBlockingTake()
375 q.take(); in testBlockingTake()
382 q.take(); in testBlockingTake()
601 assertSame(o[i], q.take()); in testToArray()
711 NanoDelay e = q.take(); in testDelay()
|
| D | ArrayBlockingQueueTest.java | 403 assertEquals(0, q.take()); in testPutWithTake()
444 assertEquals(i, q.take()); in testTake()
457 assertEquals(i, q.take()); in testBlockingTake()
462 q.take(); in testBlockingTake()
469 q.take(); in testBlockingTake()
758 assertEquals(it.next(), q.take()); in testIterator()
855 assertSame(one, q.take()); in testOfferInExecutor()
|
| D | BlockingQueueTest.java | 291 q.take();
313 q.take();
|
| D | LinkedBlockingDequeTest.java | 667 assertEquals(0, q.take()); in testPutWithTake()
708 assertEquals(i, q.take()); in testTake()
721 assertEquals(i, q.take()); in testBlockingTake()
726 q.take(); in testBlockingTake()
733 q.take(); in testBlockingTake()
897 assertEquals(capacity - 1, q.take()); in testPutFirstWithTake()
1246 assertEquals(0, q.take());
1574 assertEquals(it.next(), q.take());
1732 assertSame(one, q.take());
|
| /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());
|
| /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
|
| /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()
|