HomeSort by relevance Sort by last modified time
    Searched refs:drainTo (Results 1 - 25 of 46) sorted by null

1 2

  /libcore/luni/src/main/java/java/util/concurrent/
BlockingQueue.java 321 int drainTo(Collection<? super E> c);
346 int drainTo(Collection<? super E> c, int maxElements);
DelayQueue.java 292 * Used only by drainTo. Call only when holding lock.
307 public int drainTo(Collection<? super E> c) {
333 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 663 public int drainTo(Collection<? super E> c) {
664 return drainTo(c, Integer.MAX_VALUE);
673 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 817 * drainTo. But if the queue is a DelayQueue or any other kind of
818 * queue for which poll or drainTo may fail to remove some
824 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 135 * drainTo(null) throws NullPointerException
140 q.drainTo(null);
146 * drainTo(this) throws IllegalArgumentException
151 q.drainTo(q);
157 * drainTo(null, n) throws NullPointerException
162 q.drainTo(null, 0);
168 * drainTo(this, n) throws IllegalArgumentException
173 q.drainTo(q, 0);
179 * drainTo(c, n) returns 0 and does nothing when n <= 0
185 assertEquals(0, q.drainTo(new ArrayList(), n))
    [all...]
PriorityBlockingQueueTest.java 637 * drainTo(c) empties queue into another collection c
642 q.drainTo(l);
653 q.drainTo(l);
661 * drainTo empties queue
672 q.drainTo(l);
681 * drainTo(c, n) empties first min(n, size) elements of queue into c
689 q.drainTo(l, i);
SynchronousQueueTest.java 525 * drainTo(c) of empty queue doesn't transfer elements
532 q.drainTo(l);
538 * drainTo empties queue, unblocking a waiting put.
552 q.drainTo(l);
563 * drainTo(c, n) empties up to n elements of queue into c
579 q.drainTo(l, 1);
581 q.drainTo(l, 1);
ArrayBlockingQueueTest.java 817 * drainTo(c) empties queue into another collection c
822 q.drainTo(l);
833 q.drainTo(l);
841 * drainTo empties full queue, unblocking a waiting put.
852 q.drainTo(l);
861 * drainTo(c, n) empties first min(n, size) elements of queue into c
869 q.drainTo(l, i);
DelayQueueTest.java 707 * drainTo(c) empties queue into another collection c
717 q.drainTo(l);
727 q.drainTo(l);
735 * drainTo empties queue
746 q.drainTo(l);
753 * drainTo(c, n) empties first min(n, size) elements of queue into c
759 q.drainTo(l, i);
LinkedBlockingQueueTest.java 750 * drainTo(c) empties queue into another collection c
755 q.drainTo(l);
766 q.drainTo(l);
774 * drainTo empties full queue, unblocking a waiting put.
785 q.drainTo(l);
794 * drainTo(c, n) empties first min(n, size) elements of queue into c
802 q.drainTo(l, i);
LinkedTransferQueueTest.java 631 * drainTo(c) empties queue into another collection c
636 q.drainTo(l);
648 q.drainTo(l);
657 * drainTo(c) empties full queue, unblocking a waiting put.
666 q.drainTo(l);
675 * drainTo(c, n) empties first min(n, size) elements of queue into c
684 q.drainTo(l, i);
    [all...]
LinkedBlockingDequeTest.java     [all...]
  /external/guava/guava/src/com/google/common/collect/
Queues.java 191 * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested
208 * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make
214 // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
215 // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
216 added += q.drainTo(buffer, numElements - added);
250 // we could rely solely on #poll, but #drainTo might be more efficient when there are
251 // multiple elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
252 added += q.drainTo(buffer, numElements - added);
  /prebuilts/sdk/10/
android.jar 
  /prebuilts/sdk/11/
android.jar 
  /prebuilts/sdk/13/
android.jar 
  /prebuilts/sdk/16/
android.jar 
  /prebuilts/sdk/20/
android.jar 

Completed in 260 milliseconds

1 2