Searched refs:drainTo (Results 1 - 18 of 18) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
H A DBlockingQueue.java351 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 DDelayQueue.java326 * 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 DArrayBlockingQueue.java655 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 DLinkedBlockingQueue.java693 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 DPriorityBlockingQueue.java73 * {@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 DScheduledThreadPoolExecutor.java1208 * 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 DSynchronousQueue.java1114 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 DLinkedBlockingDeque.java732 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 DLinkedTransferQueue.java1370 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 DThreadPoolExecutor.java867 * 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 DBlockingQueueTest.java147 * 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 DPriorityBlockingQueueTest.java667 * 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 DSynchronousQueueTest.java548 * 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 DArrayBlockingQueueTest.java859 * 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 DDelayQueueTest.java741 * 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 DLinkedBlockingQueueTest.java792 * 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 DLinkedTransferQueueTest.java670 * 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 DLinkedBlockingDequeTest.java1746 * 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);

Completed in 124 milliseconds