/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 | |