| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| BlockingQueue.java | 351 int drainTo(Collection<? super E> c);
376 int drainTo(Collection<? super E> c, int maxElements);
|
| DelayQueue.java | 326 * Used only by drainTo. Call only when holding lock.
341 public int drainTo(Collection<? super E> c) {
367 public int drainTo(Collection<? super E> c, int maxElements) {
|
| ArrayBlockingQueue.java | 655 public int drainTo(Collection<? super E> c) {
656 return drainTo(c, Integer.MAX_VALUE);
665 public int drainTo(Collection<? super E> c, int maxElements) {
[all...] |
| LinkedBlockingQueue.java | 693 public int drainTo(Collection<? super E> c) {
694 return drainTo(c, Integer.MAX_VALUE);
703 public int drainTo(Collection<? super E> c, int maxElements) {
[all...] |
| PriorityBlockingQueue.java | 73 * {@code Arrays.sort(pq.toArray())}. Also, method {@code drainTo}
720 public int drainTo(Collection<? super E> c) {
721 return drainTo(c, Integer.MAX_VALUE);
730 public int drainTo(Collection<? super E> c, int maxElements) {
[all...] |
| ScheduledThreadPoolExecutor.java | [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);
|
| /external/guava/guava/src/com/google/common/collect/ |
| ForwardingBlockingDeque.java | 115 public int drainTo(Collection<? super E> c) {
116 return delegate().drainTo(c);
120 public int drainTo(Collection<? super E> c, int maxElements) {
121 return delegate().drainTo(c, maxElements);
|
| Queues.java | 247 * Drains the queue as {@link BlockingQueue#drainTo(Collection, int)}, but if the requested
265 * execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make
271 // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
272 // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
273 added += q.drainTo(buffer, numElements - added);
308 // we could rely solely on #poll, but #drainTo might be more efficient when there are
309 // multiple elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
310 added += q.drainTo(buffer, numElements - added);
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ForwardingBlockingDequeTest.java | 112 forward.drainTo(Lists.newArrayList());
113 assertEquals("[drainTo(Collection)]", getCalls());
117 forward.drainTo(Lists.newArrayList(), 3);
118 assertEquals("[drainTo(Collection,int)]", getCalls());
|
| /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 | 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();
|
| 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 | 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);
|
| 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 | 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);
[all...] |
| /prebuilts/tools/common/m2/repository/net/bytebuddy/byte-buddy-android/1.6.5/ |
| byte-buddy-android-1.6.5.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-protobuf/0.13.2/ |
| grpc-protobuf-0.13.2.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-protobuf-lite/1.0.1/ |
| grpc-protobuf-lite-1.0.1.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-protobuf-lite/1.0.3/ |
| grpc-protobuf-lite-1.0.3.jar | |
| /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);
|
| /packages/apps/Dialer/java/com/android/dialer/persistentlog/ |
| PersistentLogger.java | 83 messageQueue.drainTo(messages);
|
