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

Comparing jsr166/src/main/java/util/concurrent/ConcurrentLinkedDeque.java (file contents):
Revision 1.81 by jsr166, Sat Dec 24 04:27:02 2016 UTC vs.
Revision 1.82 by jsr166, Sat Dec 24 11:14:37 2016 UTC

# Line 1403 | Line 1403 | public class ConcurrentLinkedDeque<E>
1403                          if (p == (p = p.next))
1404                              p = first();
1405                      } while (p != null && i < n);
1406 <                    if ((current = p) == null)
1407 <                        exhausted = true;
1406 >                    exhausted = ((current = p) == null);
1407                      if (i > 0) {
1408                          batch = i;
1409                          return Spliterators.spliterator
# Line 1422 | Line 1421 | public class ConcurrentLinkedDeque<E>
1421              if (action == null) throw new NullPointerException();
1422              if (!exhausted &&
1423                  ((p = current) != null || (p = first()) != null)) {
1424 +                current = null;
1425                  exhausted = true;
1426                  do {
1427                      E e = p.item;
# Line 1444 | Line 1444 | public class ConcurrentLinkedDeque<E>
1444                      if (p == (p = p.next))
1445                          p = first();
1446                  } while (e == null && p != null);
1447 <                if ((current = p) == null)
1448 <                    exhausted = true;
1447 >                exhausted = ((current = p) == null);
1448                  if (e != null) {
1449                      action.accept(e);
1450                      return true;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines