| /libcore/luni/src/main/java/java/util/concurrent/ |
| BlockingQueue.java | 322 int drainTo(Collection<? super E> c);
347 int drainTo(Collection<? super E> c, int maxElements);
|
| DelayQueue.java | 293 * Used only by drainTo. Call only when holding lock.
308 public int drainTo(Collection<? super E> c) {
334 public int drainTo(Collection<? super E> c, int maxElements) {
|
| LinkedBlockingQueue.java | 683 public int drainTo(Collection<? super E> c) {
684 return drainTo(c, Integer.MAX_VALUE);
693 public int drainTo(Collection<? super E> c, int maxElements) {
|
| ArrayBlockingQueue.java | 645 public int drainTo(Collection<? super E> c) {
646 return drainTo(c, Integer.MAX_VALUE);
655 public int drainTo(Collection<? super E> c, int maxElements) {
[all...] |
| LinkedBlockingDeque.java | 701 public int drainTo(Collection<? super E> c) {
702 return drainTo(c, Integer.MAX_VALUE);
711 public int drainTo(Collection<? super E> c, int maxElements) {
[all...] |
| PriorityBlockingQueue.java | 34 * {@code Arrays.sort(pq.toArray())}. Also, method {@code drainTo}
722 public int drainTo(Collection<? super E> c) {
723 return drainTo(c, Integer.MAX_VALUE);
732 public int drainTo(Collection<? super E> c, int maxElements) {
|
| LinkedTransferQueue.java | [all...] |
| ScheduledThreadPoolExecutor.java | [all...] |
| SynchronousQueue.java | [all...] |
| ThreadPoolExecutor.java | 818 * drainTo. But if the queue is a DelayQueue or any other kind of
819 * queue for which poll or drainTo may fail to remove some
825 q.drainTo(taskList);
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ForwardingBlockingQueue.java | 44 @Override public int drainTo(
46 return delegate().drainTo(c, maxElements);
49 @Override public int drainTo(Collection<? super E> c) {
50 return delegate().drainTo(c);
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| 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(new ArrayList(), n))
[all...] |
| 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);
|
| SynchronousQueueTest.java | 545 * drainTo(c) of empty queue doesn't transfer elements
552 q.drainTo(l);
558 * drainTo empties queue, unblocking a waiting put.
572 q.drainTo(l);
583 * drainTo(c, n) empties up to n elements of queue into c
599 q.drainTo(l, 1);
601 q.drainTo(l, 1);
|
| 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);
|
| DelayQueueTest.java | 737 * drainTo(c) empties queue into another collection c
747 q.drainTo(l);
757 q.drainTo(l);
765 * drainTo empties queue
776 q.drainTo(l);
783 * drainTo(c, n) empties first min(n, size) elements of queue into c
789 q.drainTo(l, i);
|
| 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);
|
| LinkedTransferQueueTest.java | 663 * drainTo(c) empties queue into another collection c
668 q.drainTo(l);
680 q.drainTo(l);
689 * drainTo(c) empties full queue, unblocking a waiting put.
698 q.drainTo(l);
707 * drainTo(c, n) empties first min(n, size) elements of queue into c
716 q.drainTo(l, i);
[all...] |
| LinkedBlockingDequeTest.java | [all...] |
| /external/guava/guava/src/com/google/common/collect/ |
| Queues.java | 181 * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested
199 * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make
205 // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
206 // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
207 added += q.drainTo(buffer, numElements - added);
242 // we could rely solely on #poll, but #drainTo might be more efficient when there are
243 // multiple elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
244 added += q.drainTo(buffer, numElements - added);
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MonitorBasedPriorityBlockingQueue.java | 52 * <tt>Arrays.sort(pq.toArray())</tt>. Also, method <tt>drainTo</tt>
395 public int drainTo(Collection<? super E> c) {
422 public int drainTo(Collection<? super E> c, int maxElements) {
|
| MonitorBasedArrayBlockingQueue.java | 593 public int drainTo(Collection<? super E> c) {
629 public int drainTo(Collection<? super E> c, int maxElements) {
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| ConcurrentBufferQueue.java | 120 mQueue.drainTo(remainingElements);
|
| /external/jetty/src/java/org/eclipse/jetty/util/ |
| BlockingArrayQueue.java | 651 public int drainTo(Collection<? super E> c)
657 public int drainTo(Collection<? super E> c, int maxElements)
|
| /prebuilts/sdk/22/ |
| android.jar | |
