Searched defs:maxElements (Results 1 - 9 of 9) sorted by relevance

/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DBlockingQueue.java365 * @param maxElements the maximum number of elements to transfer
376 int drainTo(Collection<? super E> c, int maxElements); argument
H A DDelayQueue.java349 public int drainTo(Collection<? super E> c, int maxElements) { argument
354 if (maxElements <= 0)
360 while (n < maxElements) {
H A DArrayBlockingQueue.java673 public int drainTo(Collection<? super E> c, int maxElements) { argument
677 if (maxElements <= 0)
685 int max = (maxElements < count) ? maxElements : count;
H A DLinkedBlockingQueue.java726 public int drainTo(Collection<? super E> c, int maxElements) { argument
735 int n = Math.min(maxElements, count.get());
H A DPriorityBlockingQueue.java761 public int drainTo(Collection<? super E> c, int maxElements) { argument
766 if (maxElements <= 0)
771 int n = Math.min(size, maxElements);
H A DLinkedBlockingDeque.java740 public int drainTo(Collection<? super E> c, int maxElements) { argument
748 int n = Math.min(maxElements, count);
H A DLinkedTransferQueue.java1177 public int drainTo(Collection<? super E> c, int maxElements) { argument
1184 while (n < maxElements && (e = poll()) != null) {
H A DScheduledThreadPoolExecutor.java1194 public int drainTo(Collection<? super Runnable> c, int maxElements) { argument
1199 if (maxElements <= 0)
1206 while (n < maxElements && (first = pollExpired()) != null) {
H A DSynchronousQueue.java1120 public int drainTo(Collection<? super E> c, int maxElements) { argument
1127 while (n < maxElements && (e = poll()) != null) {

Completed in 49 milliseconds