# | 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; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |