zoukankan      html  css  js  c++  java
  • ConcurrentLinkedQueue offer() 内部方法实现

    // 注意:不同的颜色,表示不同的逻辑,前面的数字,是他们各自的逻辑顺序,
    //这个方法没有任何的锁操作,线程安全完全是由cas操作和队列的算法来保证的,整个方法的核心是for循环,这个循环没有出口,知道尝试成功
    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) {
            //1、如果第一次进来,次条件成立
            // 1、程序再次进入,此时,t和p还在head位置上,(由于第一次插入了数据)q!=null
            // 3、p取到了下一个节点(“直到”最后的节点)q==null
          if (p.casNext(null, newNode)) {// p是最后一个节点 
            //每2次更新一下tail
          if (p != t)
              // 2、如果是第一次进来,那么t==p是成立,所以不会执行下一句话,所以呢,就不会更新t节点,也就是不会更新tail
              // 4、经过第二步,p已经不能t了,所以,更新tail节点,由此可以看书,不是每次都更新tail的
            casTail(t, newNode); // Failure is OK.
            return true;
          }
          // cas竞争失败,再次尝试,
        }
        else if (p == q)// 遇到哨兵节点,从head开始遍历(哨兵节点的产生是因为,链表进行了poll()“提取删除”操作)
              //但如果tail被修改了,则使用tail(因为可能被修改正确了),
              // t!=(t=tail)这个操作在并行中是永false,但是在串行中,由于可能对比的时候,t的值被其他线程修改,所以,此值可能为turl
        p = (t != (t = tail)) ? t : head;
        else
        //2、p取下一个节点或者最后一个节点
        p = (p != t && t != (t = tail)) ? t : q;
      }
    }

  • 相关阅读:
    洛谷 P3384 【模板】树链剖分
    codevs 4633 [Mz]树链剖分练习
    看一个人的回答有感(怎么判断数组中有没有未定义的值,如:[,,1,,3])
    bzoj2754: [SCOI2012]喵星球上的点名
    bzoj4456: [Zjoi2016]旅行者
    bzoj4574:Zjoi2016线段树 dp
    bzoj4455: [Zjoi2016]小星星
    bzoj4516: [Sdoi2016]生成魔咒
    uoj#207. 共价大爷游长沙
    bzoj4530:[Bjoi2014]大融合
  • 原文地址:https://www.cnblogs.com/sg9527/p/8005366.html
Copyright © 2011-2022 走看看