/libcore/ojluni/src/main/java/java/util/concurrent/ |
H A D | BlockingQueue.java | 351 int drainTo(Collection<? super E> c); method in interface:BlockingQueue 376 int drainTo(Collection<? super E> c, int maxElements); method in interface:BlockingQueue
|
H A D | DelayQueue.java | 326 * Used only by drainTo. Call only when holding lock. 341 public int drainTo(Collection<? super E> c) { method in class:DelayQueue 367 public int drainTo(Collection<? super E> c, int maxElements) { method in class:DelayQueue
|
H A D | ArrayBlockingQueue.java | 655 public int drainTo(Collection<? super E> c) { method in class:ArrayBlockingQueue 656 return drainTo(c, Integer.MAX_VALUE); 665 public int drainTo(Collection<? super E> c, int maxElements) { method in class:ArrayBlockingQueue
|
H A D | LinkedBlockingQueue.java | 693 public int drainTo(Collection<? super E> c) { method in class:LinkedBlockingQueue 694 return drainTo(c, Integer.MAX_VALUE); 703 public int drainTo(Collection<? super E> c, int maxElements) { method in class:LinkedBlockingQueue
|
H A D | PriorityBlockingQueue.java | 73 * {@code Arrays.sort(pq.toArray())}. Also, method {@code drainTo} 720 public int drainTo(Collection<? super E> c) { method in class:PriorityBlockingQueue 721 return drainTo(c, Integer.MAX_VALUE); 730 public int drainTo(Collection<? super E> c, int maxElements) { method in class:PriorityBlockingQueue
|
H A D | ScheduledThreadPoolExecutor.java | 1208 * Used only by drainTo. Call only when holding lock. 1217 public int drainTo(Collection<? super Runnable> c) { method in class:ScheduledThreadPoolExecutor.DelayedWorkQueue 1238 public int drainTo(Collection<? super Runnable> c, int maxElements) { method in class:ScheduledThreadPoolExecutor.DelayedWorkQueue
|
H A D | SynchronousQueue.java | 1114 public int drainTo(Collection<? super E> c) { method in class:SynchronousQueue 1133 public int drainTo(Collection<? super E> c, int maxElements) { method in class:SynchronousQueue
|
H A D | LinkedBlockingDeque.java | 732 public int drainTo(Collection<? super E> c) { method in class:LinkedBlockingDeque 733 return drainTo(c, Integer.MAX_VALUE); 742 public int drainTo(Collection<? super E> c, int maxElements) { method in class:LinkedBlockingDeque
|
H A D | LinkedTransferQueue.java | 1370 public int drainTo(Collection<? super E> c) { method in class:LinkedTransferQueue 1387 public int drainTo(Collection<? super E> c, int maxElements) { method in class:LinkedTransferQueue
|
H A D | ThreadPoolExecutor.java | 867 * drainTo. But if the queue is a DelayQueue or any other kind of 868 * queue for which poll or drainTo may fail to remove some 874 q.drainTo(taskList);
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | BlockingQueueTest.java | 147 * drainTo(null) throws NullPointerException 152 q.drainTo(null); 158 * drainTo(this) throws IllegalArgumentException 163 q.drainTo(q); 169 * drainTo(null, n) throws NullPointerException 174 q.drainTo(null, 0); 180 * drainTo(this, n) throws IllegalArgumentException 185 q.drainTo(q, 0); 191 * drainTo(c, n) returns 0 and does nothing when n <= 0 197 assertEquals(0, q.drainTo(ne [all...] |
H A D | PriorityBlockingQueueTest.java | 667 * drainTo(c) empties queue into another collection c 672 q.drainTo(l); 683 q.drainTo(l); 691 * drainTo empties queue 702 q.drainTo(l); 711 * drainTo(c, n) empties first min(n, size) elements of queue into c 719 q.drainTo(l, i);
|
H A D | SynchronousQueueTest.java | 548 * drainTo(c) of empty queue doesn't transfer elements 555 q.drainTo(l); 561 * drainTo empties queue, unblocking a waiting put. 575 q.drainTo(l); 586 * drainTo(c, n) empties up to n elements of queue into c 602 while ((drained = q.drainTo(l, 1)) == 0) Thread.yield(); 605 while ((drained = q.drainTo(l, 1)) == 0) Thread.yield();
|
H A D | ArrayBlockingQueueTest.java | 859 * drainTo(c) empties queue into another collection c 864 q.drainTo(l); 875 q.drainTo(l); 883 * drainTo empties full queue, unblocking a waiting put. 894 q.drainTo(l); 903 * drainTo(c, n) empties first min(n, size) elements of queue into c 911 q.drainTo(l, i);
|
H A D | DelayQueueTest.java | 741 * drainTo(c) empties queue into another collection c 751 q.drainTo(l); 761 q.drainTo(l); 769 * drainTo empties queue 780 q.drainTo(l); 787 * drainTo(c, n) empties first min(n, size) elements of queue into c 793 q.drainTo(l, i);
|
H A D | LinkedBlockingQueueTest.java | 792 * drainTo(c) empties queue into another collection c 797 q.drainTo(l); 808 q.drainTo(l); 816 * drainTo empties full queue, unblocking a waiting put. 827 q.drainTo(l); 836 * drainTo(c, n) empties first min(n, size) elements of queue into c 844 q.drainTo(l, i);
|
H A D | LinkedTransferQueueTest.java | 670 * drainTo(c) empties queue into another collection c 675 q.drainTo(l); 687 q.drainTo(l); 696 * drainTo(c) empties full queue, unblocking a waiting put. 705 q.drainTo(l); 714 * drainTo(c, n) empties first min(n, size) elements of queue into c 723 q.drainTo(l, i);
|
H A D | LinkedBlockingDequeTest.java | 1746 * drainTo(c) empties deque into another collection c 1751 q.drainTo(l); 1762 q.drainTo(l); 1770 * drainTo empties full deque, unblocking a waiting put. 1781 q.drainTo(l); 1790 * drainTo(c, n) empties first min(n, size) elements of queue into c 1798 q.drainTo(l, i);
|