7

http://www.java2s.com/Open-Source/Java-Open-Source-Library/7-JDK/java/java/util/concurrent/ConcurrentLinkedQueue.java.htm

以上是 ConcurrentLinkedQueue 的源码。我无法理解一种情况。

条件(p == q)将如何出现在 offer 方法的以下代码段中

  public boolean offer(E e) {
        checkNotNull(e);
        final Node<E> newNode = new Node<E>(e);

        for (Node<E> t = tail, p = t;;) {
            Node<E> q = p.next;
            if (q == null) {
                // p is last node
                if (p.casNext(null, newNode)) {
                    // Successful CAS is the linearization point
                    // for e to become an element of this queue,
                    // and for newNode to become "live".
                    if (p != t) // hop two nodes at a time
                        casTail(t, newNode);  // Failure is OK.
                    return true;
                }
                // Lost CAS race to another thread; re-read next
            }
            else if (p == q)
                // We have fallen off list.  If tail is unchanged, it
                // will also be off-list, in which case we need to
                // jump to head, from which all live nodes are always
                // reachable.  Else the new tail is a better bet.
                p = (t != (t = tail)) ? t : head;
            else
                // Check for tail updates after two hops.
                p = (p != t && t != (t = tail)) ? t : q;
        }
    }

还有作者所说的“我们已经从名单上掉下来”是什么意思

4

2 回答 2

6

允许在ConcurrentLinkedQueue遍历内部列表时同时修改内部列表。这意味着您正在查看的节点可能已被同时删除。为了检测这种情况，被移除节点的下一个指针被改变为指向它自己。详情请updateHead参阅 (L302)。

于 2013-09-09T11:51:06.897 回答
2

条件询问“当前节点是否与下一个节点相同？”的问题。

如果是这样，你已经从列表中掉了出来（文档在行。）

步骤的基本大纲是：

  1. 为提供的数据创建一个新节点。
  2. 遍历列表以找到最后一个节点
  3. 插入新节点作为新的尾部。

if 语句的其他部分正在处理并发修改问题。

为了更好地理解发生了什么，请阅读 Node.casTail() 和 casNext()

于 2013-09-09T11:23:46.463 回答