6871697: LinkedBlockingQueue Iterator/remove/poll race
authordl
Tue, 25 Aug 2009 19:19:42 -0700
changeset 3707 67e8505ef721
parent 3706 243a2d1d9902
child 3708 f838f712922e
6871697: LinkedBlockingQueue Iterator/remove/poll race Summary: More checks for node.next == node Reviewed-by: martin, dholmes, chegar
jdk/src/share/classes/java/util/concurrent/LinkedBlockingQueue.java
--- a/jdk/src/share/classes/java/util/concurrent/LinkedBlockingQueue.java	Wed Aug 26 12:17:29 2009 +0800
+++ b/jdk/src/share/classes/java/util/concurrent/LinkedBlockingQueue.java	Tue Aug 25 19:19:42 2009 -0700
@@ -766,19 +766,21 @@
         }
 
         /**
-         * Unlike other traversal methods, iterators need to handle:
+         * Returns the next live successor of p, or null if no such.
+         *
+         * Unlike other traversal methods, iterators need to handle both:
          * - dequeued nodes (p.next == p)
-         * - interior removed nodes (p.item == null)
+         * - (possibly multiple) interior removed nodes (p.item == null)
          */
         private Node<E> nextNode(Node<E> p) {
-            Node<E> s = p.next;
-            if (p == s)
-                return head.next;
-            // Skip over removed nodes.
-            // May be necessary if multiple interior Nodes are removed.
-            while (s != null && s.item == null)
-                s = s.next;
-            return s;
+            for (;;) {
+                Node<E> s = p.next;
+                if (s == p)
+                    return head.next;
+                if (s == null || s.item != null)
+                    return s;
+                p = s;
+            }
         }
 
         public E next() {