Java AbstractQueuedSynchronizer源码阅读2-addWaiter()

AbstractQueuedSynchronizer既然是同步器实现框架,关键便在于处理好多线程运行时的问题。通过Java AbstractQueuedSynchronizer源码阅读1-基于队列的同步器框架,可以了解到addWaiter()的功能是将Node入队,那么addWaiter()是如何保证多线程运行下入队操作的正确性的呢?

addWaiter()使用了原子性方法compareAndSetTail()。为方便叙述,将addWater()的代码粘贴如下:

private Node addWaiter(Node mode) {
        Node node = new Node(Thread.currentThread(), mode);//新建与一个当前线程关联的node
        // Try the fast path of enq; backup to full enq on failure
        Node pred = tail;
        if (pred != null) {//如果tail不为空
            node.prev = pred;//将新建的node加入到队尾
            if (compareAndSetTail(pred, node)) {//调用CAS(CompareAndSet)重新设置tail
                pred.next = node;
                return node;
            }
        }
        //如果入队失败了,则调用enq()
        enq(node);
        return node;
    }

compareAndSetTail(pred, node)会比较pred和tail是否指向同一个节点,如果是,才将tail更新为node。为何不是直接赋值,而要多做一步比较操作呢?那是因为虽然当前线程在声明pred时,为pred赋值了tail,但tail可能会被其他线程改变,而当前线程的本地变量pred是不会感知到这个改变的。

这里,通过模拟多线程执行来加深这个理解。

假设队列的初始状态如下,只有一个Node(称为Node0),队列的head和tail都指向Node0。


队列的初始状态

现在有线程A和线程B同时调用addWaiter(),要向该队列插入新的Node。假设线程A和线程B的执行流程如下图所示(省略了部分代码,并对代码采取了简写):


线程A和线程B的执行流程

第1步:线程A新建了Node(称为NodeA),并开始入队。但是,线程A仅来的及将NodeA的prev指针赋值为tail,便被调度出处理器。此时队列的状态如下图所示,NodeA的prev指向了Node0。图中还另外标注了线程A的局部变量pred,也是指向Node0的。


第1步

第2步:紧接着,线程B开始占用处理器,执行第2步。线程2也新建了一个Node(称为NodeB),并且线程B成功的执行完addWaiter(),将NodeB入队。此时队列的状态如下图所示,NodeB的prev也指向了Node0。此处关键要注意的是,tail此时已经指向了NodeB,但是线程A的pred依然指向Node0。


第2步

第3步:线程B在入队完成后,线程A又开始占用处理器执行。线程A调用compareAndSetTail(pred, tail),发现pred和tail并不是指向同一个Node的,该方法会返回false,线程A尝试快速入队失败。之后,线程A会调用enq(),重新获取tail,并不停尝试入队直到成功。这里不再展开enq()方法。最终队列的状态会如下所示,线程B因为先于线程A成功调用了compareAndSetTail(),而位于A的前面。


队列最终状态

如果使用的不是CAS方法,而是直接采用赋值的方式(即将compareAndSetTail(pred, node)换成tail=node),则在第3步时,会得到下面这个错误的结果。


错误的入队

所以说,入队的同步关键在于原子性的compareAndSetTail()方法。它保证了每个线程能够完整的执行下面两个操作:

  1. 设置prev,将自己链接到队尾;
  2. 将tail更新为自己。

这使得队列中的tail和prev指针总是可靠的,用户在任何时候都可以使用tail和prev去访问队列。


提出一些问题

为何不将如下入队的两步关键性操作封装为原子性操作

  1. 设置prev,将自己链接到队尾;
  2. 将tail更新为自己。

如果将这两步封装为原子性操作,那么正确的入队就可以一次性完成。而原本的实现中,CAS失败后,还需要再重试。但是,AbstractQueuedSynchronizer本身是要实现原子性的操作,而其本身又依赖原子性的操作,感觉有点像是先有鸡还是先有蛋的问题了。
其实,CAS的原子性是依赖机器指令实现的,但是机器指令无法支持以上两步执行的原子性。AbstractQueuedSynchronizer采取的方法是,依赖原子性的CAS以及循环,来实现上述两步的原子性。

为何addWaiter()实现时,是按照下面这个顺序

  1. 设置prev指针;
  2. compareAndSetTail();
  3. 设置next指针;

而不是3-2-1或是1-3-2这种顺序呢?

对于3-2-1,我认为,其实和1-2-3的本质上是一样的,只是代码实现时,选择prev指针而已。1-2-3这种方式保证了prev的可靠性,可以看到AbstractQueuedSynchronizer中一些需要遍历队列的方法,如getQueuedThreads(),都是使用的prev。

对于1-3-2,我们可以按照上面的图"线程A和线程B的执行流程“,再推演一遍,可以发现,线程A在快速入队时,对NodeA的prev指针和next指针的设置都浪费了。而1-2-3的顺序下,仅是浪费了设置prev指针这一步。

总而言之,addWaiter()的实现保证了prev指针的可靠性。

那么,next指针既然不可靠,那为何还需要呢?prev指针不是已经保证了队列的可访问性了么?引用源码中对Node的注释。

We also use "next" links to implement blocking mechanics. The thread id for each node is kept in its own node, so a predecessor signals the next node to wake up by traversing next link to determine which thread it is. Determination of successor must avoid races with newly queued nodes to set the "next" fields of their predecessors. This is solved when necessary by checking backwards from the atomically updated "tail" when a node's successor appears to be null. (Or, said differently, the next-links are an optimization so that we don't usually need a backward scan.)

这段话的大意是说某个节点在释放锁时,需要唤醒其后继节点。如果没有next指针,那么每次都需要从tail往前遍历,next指针则优化了这一操作。但是要注意的是,因为next指针并不可靠,所以有时候next指针会是null,此时,依然需要依赖tail指针向前回溯,以找到期望的节点。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,194评论 6 490
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,058评论 2 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 156,780评论 0 346
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,388评论 1 283
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,430评论 5 384
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,764评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,907评论 3 406
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,679评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,122评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,459评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,605评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,270评论 4 329
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,867评论 3 312
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,734评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,961评论 1 265
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,297评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,472评论 2 348

推荐阅读更多精彩内容