ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/ConcurrentLinkedQueue.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/ConcurrentLinkedQueue.java (file contents):
Revision 1.137 by jsr166, Sat Dec 24 19:32:07 2016 UTC vs.
Revision 1.138 by jsr166, Mon Dec 26 17:29:34 2016 UTC

# Line 813 | Line 813 | public class ConcurrentLinkedQueue<E> ex
813                      if (p == (p = p.next))
814                          p = first();
815                  } while (p != null && i < n);
816 <                exhausted = ((current = p) == null);
816 >                if ((current = p) == null)
817 >                    exhausted = true;
818                  if (i > 0) {
819                      batch = i;
820                      return Spliterators.spliterator
# Line 853 | Line 854 | public class ConcurrentLinkedQueue<E> ex
854                      if (p == (p = p.next))
855                          p = first();
856                  } while (e == null && p != null);
857 <                exhausted = ((current = p) == null);
857 >                if ((current = p) == null)
858 >                    exhausted = true;
859                  if (e != null) {
860                      action.accept(e);
861                      return true;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines