死磕 Java 并发编程（9）：无界线程安全队列 ConcurrentLinkedQueue 源码解析

// 将指定的元素插入到此队列的末尾,因为队列是无界的，所以这个方法永远不会返回 false 。public boolean offer(E e) {    checkNotNull(e);    // 入队前，创建一个入队节点    final Node<E> newNode = new Node<E>(e);    // 死循环，入队不成功反复入队    // 创建一个指向tail节点的引用,p用来表示队列的尾节点，默认情况下等于tail节点    for (Node<E> t = tail, p = t;;) {        // 获得p节点的下一个节点        Node<E> q = p.next;        // next节点为空，说明p是尾节点        if (q == null) {            // p is last node            // p是尾结点，则设置p节点的next节点为入队节点            if (p.casNext(null, newNode)) {                // 首先要知道入队操作不是每次都设置tail节点为尾结点，为了减少CAS操作提高性能,也就是说tail节点不总是尾节点                // 如果tail节点有大于等于1个next节点，则将入队节点设置成tail节点，                // p != t 这个条件者结合下面 else 分支看，下面在冲突的时候会修改 p 指向 p.next，所以导致p不等于 tail,                // 即tail节点有大于等于1个的next节点                if (p != t) // hop two nodes at a time                    // 如果tail节点有大于等于1个next节点，则将入队节点设置成tail节点，                    // 这里允许失败，更新失败了也没关系，因为失败了表示有其他线程成功更新了tail节点                    casTail(t, newNode);  // Failure is OK.                return true;            }            // Lost CAS race to another thread; re-read next        }        // 这个分支要想进去，即 p 节点等于 p.next 节点，只有一种可能，就是 p 节点和 p.next 节点都为空        // 表示这队列刚初始化，正准备添加节点，所以需要返回head        else if (p == q)            // 如果tail变了，说明被其他线程添加成功了，则 p 取新的 tail，否则 p 从 head 开始            p = (t != (t = tail)) ? t : head;        else            // Check for tail updates after two hops.            // 进行这个分支说明next节点不为空，说明p不是尾节点，需要更新p后在将它指向next节点            // 执行 p != t 说明尾结点不等于tail，t != (t = tail)) 说明tail做了变动，            // 同时满足说明tail已经重新设置了，即结尾就是tail，否则尾结点取tail.next            p = (p != t && t != (t = tail)) ? t : q;    }}

public boolean offer(E e) {    if (e == null)         throw new NullPointerException();    Node<E> n = new Node<E>(e);     for (;;) {        Node<E> t = tail;        if (t.casNext(null, n) && casTail(t, n)) {             return true;         }     } }

// 从队头出队public E poll() {    restartFromHead:    for (;;) {        // p 表示头节点，需要出队的节点        for (Node<E> h = head, p = h, q;;) {            // 获取p节点的元素            E item = p.item;            // 如果头节点p中元素不为空，则进行CAS清空p节点对元素的应用，返回p节点的元素            if (item != null && p.casItem(item, null)) {                // CAS 设为成功后进入到这里，需要判断头节点p是否和head节点不是同一个了，即头节点p已经变更了                if (p != h) // hop two nodes at a time                    // 更新head节点，将p节点的next节点设为head节点，如果p.next不为空则设置p.next，否则设置p本身                    updateHead(h, ((q = p.next) != null) ? q : p);                return item;            }            // 到这说明头节点p中的元素为null或者发生冲突CAS失败,CAS失败也说明被别的线程取走了当前元素，所以就该取一个节点即next节点            // 如果队列头节点p的next节点为空，说明队列已空，将则head设为p，返回null            else if ((q = p.next) == null) {                updateHead(h, p);                return null;            }            // 进到这里说明 (q = p.next) == null 返回false，即p的next不为空            // 同时q=p.next，而这个分支是说p=p.next,只有队列初始化时满足条件，两者都为空，则返回head，重头开始赋值            else if (p == q)                continue restartFromHead;            else                // 说明p节点的next不为空，且队列不是初始化状态，所以头节点p指向p.next                p = q;        }    }}