[ViewVC] Diff of: jsr166/jsr166/src/main/java/util/concurrent/PriorityBlockingQueue.java

Comparing jsr166/src/main/java/util/concurrent/PriorityBlockingQueue.java (file contents):
Revision 1.25 by dl, Sat Sep 20 00:31:08 2003 UTC vs.
Revision 1.26 by dl, Sun Oct 5 23:00:18 2003 UTC

-+
+    public int drainTo(Collection<? super E> c) {
-+
+        if (c == null)
-+
+            throw new NullPointerException();
-+
+        if (c == this)
-+
+            throw new IllegalArgumentException();
-+
+        lock.lock();
-+
+        try {
-+
+            int n = 0;
-+
+            E e;
-+
+            while ( (e = q.poll()) != null) {
-+
+                c.add(e);
-+
+                ++n;
-+
+            }
-+
+            return n;
-+
+        } finally {
-+
+            lock.unlock();
-+
+        }
-+
+    }
-+
-+
+    public int drainTo(Collection<? super E> c, int maxElements) {
-+
+        if (c == null)
-+
+            throw new NullPointerException();
-+
+        if (c == this)
-+
+            throw new IllegalArgumentException();
-+
+        if (maxElements <= 0)
-+
+            return 0;
-+
+        lock.lock();
-+
+        try {
-+
+            int n = 0;
-+
+            E e;
-+
+            while (n < maxElements && (e = q.poll()) != null) {
-+
+                c.add(e);
-+
+                ++n;
-+
+            }
-+
+            return n;
-+
+        } finally {
-+
+            lock.unlock();
-+
+        }
-+
+    }
-+
+    /**
+     * Atomically removes all of the elements from this delay queue.
+     * The queue will be empty after this call returns.

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines