zoukankan      html  css  js  c++  java
  • AbstractQueuedSynchronizer--基于CAS自旋volatile变量插入尾节点

        private transient volatile Node tail;
        
          private Node enq(final Node node) {
                for (;;) {
                    Node t = tail;
                    if (t == null) { // Must initialize
                        if (compareAndSetHead(new Node()))
                            tail = head;
                    } else {
                        node.prev = t;
                        if (compareAndSetTail(t, node)) {
                            t.next = node;
                            return t;
                        }
                    }
                }
            }

    上述代码是AbstractQueuedSynchronizer中关于如何往Node中添加尾节点的代码,使用的CAS自旋volatile变量法,解决高并发下插入尾节点不同步问题。

    1.假如尾节点为空,说明节点队列为空,初始化一个头结点指向尾节点的队列;

    2.继续for循环,这次进入else中,先把插入节点的前置指向尾节点(这个尾节点不一定是真的尾节点,有可能在此期间被其他线程改变了,所以有下面的),然后进行cas操作,假如t是此时真实的尾节点,就将node改为尾节点,并将t.next指向node,然后返回。

    如果compareAndSetTail(t, node)为false,说明这个尾节点不是真的尾节点,在此期间被其他线程改变了,故继续自旋 ,Node t = tail 会一直将自认为的尾节点赋给t,直至compareAndSetTail成功。

        private Node addWaiter(Node mode) {
            Node node = new Node(Thread.currentThread(), mode);
            // Try the fast path of enq; backup to full enq on failure
            Node pred = tail;
            if (pred != null) {
                node.prev = pred;
                if (compareAndSetTail(pred, node)) {
                    pred.next = node;
                    return node;
                }
            }
            enq(node);
            return node;
        }

    上述addWaiter方法提供了一种快捷一点的插入节点方法,将空队列和自旋的判断放在enq(node)中,提升了速度,设计的很精巧

  • 相关阅读:
    leetcode16 3-Sum
    leetcode679:24Game
    leetcode621 贪心:任务安排
    SpringMVC中的Controller默认单例
    O(n)复杂度求没有出现的数字(leetcode448)
    SpringBoot获取ApplicationContext
    Largest Number(leetcode 179)
    使用免费ip代理进行投票
    Oracle分页
    Oracle JDBC配置
  • 原文地址:https://www.cnblogs.com/ljjnbpy/p/10029797.html
Copyright © 2011-2022 走看看