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

Comparing jsr166/src/main/java/util/concurrent/LinkedTransferQueue.java (file contents):
Revision 1.100 by jsr166, Sat Dec 24 04:32:50 2016 UTC vs.
Revision 1.101 by jsr166, Sat Dec 24 08:29:02 2016 UTC

# Line 441 | Line 441 | public class LinkedTransferQueue<E> exte
441           * Constructs a new node.  Uses relaxed write because item can
442           * only be seen after publication via casNext.
443           */
444 <        Node(Object item, boolean isData) {
444 >        Node(Object item) {
445              ITEM.set(this, item); // relaxed write
446 <            this.isData = isData;
446 >            isData = (item != null);
447          }
448  
449          /**
# Line 602 | Line 602 | public class LinkedTransferQueue<E> exte
602  
603              if (how != NOW) {                 // No matches available
604                  if (s == null)
605 <                    s = new Node(e, haveData);
605 >                    s = new Node(e);
606                  Node pred = tryAppend(s, haveData);
607                  if (pred == null)
608                      continue retry;           // lost race vs opposite mode

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines