线程-AQS

1, 线程同步一般有两种基础设施:mutex和condition variable

mutex
condition variable

mutex对应java中的锁,condition variable对应java中的wait/notify

java中的锁和wait/notify都有两种:

1, 对象固有的,锁对应oop中的mark word中的锁标志位,也即是synchronized底层的实现机制,wait/notify对应Object中的对应方法。

但是基于对象固有锁的synchronized不能跨越方法边界。wait/notify依赖synchronized,所以会有相同的限制。

于是就有了今天的主角:java.util.concurrent.locks.AbstractQueuedSynchronizer,简称AQS

AQS类似hotspot中对象固有锁的实现机制,重新实现了mutex和condition variable,移除了不能跨越方法边界的限制,使得CountDownLatch之类的高级同步原语可以方便的实现。

2, 从AQS的名字可以看出来是基于队列实现的,AQS的核心状态都在head和tail表示的双链表队列上,另一个状态是int类型的state。AQS基于抽象模板设计模式实现了锁机制,保留了4个try开头的protected方法基于读写state实现具体的锁机制。

tryAcquire:尝试获取互斥锁,子类应该先检查state是否允许获取互斥锁

tryRelease:修改state表明互斥锁被释放

tryAcquireShared:尝试获取共享锁,子类应该先检查state是否允许获取共享锁,return 负值表示获取共享锁失败,0表示后续节点不能获取共享锁,正数表示后续节点也能获取共享锁

tryReleaseShared:修改state表明共享锁被释放

下面围绕互斥锁/共享锁的获取和释放分析AQS实现机制

3, 获取互斥锁

获取互斥锁

先尝试获取锁,失败之后,加入同步队列

等待被唤醒,成为队列中的第一个节点,获取锁

加入队列之后,死循环,直到当前线程成为第一个节点,然后再尝试获取锁,获取锁成功之后,当前节点成为head节点

获取锁失败之后,确保有机会被唤醒

获取锁失败时,确保当前线程有机会被队列中的前置节点唤醒,理解此处需要参考下文释放共享锁的过程

暂停当前线程,检查暂停过程中是否被打断过

获取共享锁失败,确保有机会被唤醒之后,暂停当前线程等待被唤醒,然后检查暂停过程中是否被打断过。

4, 释放互斥锁


释放互斥锁

释放互斥锁,唤醒后继节点,参照前面获取锁的过程,节点不在队列头时,会被暂停等待被队列前面的节点唤醒,正是此处,唤醒后继节点,让后继节点有机会获取锁

唤醒后继节点

查找后继节点中的第一个非cancel节点,唤醒它,让它有机会获取锁。

5, 获取共享锁


获取共享锁

跟互斥锁实现类似,先尝试获取共享锁

获取共享锁

尝试失败之后,加入同步队列,跟互斥锁实现基本相同,除了简单的setHead换成了setHeadAndPropagate

传播共享锁

获取锁成功之后,当前线程所在节点成为head。tryAcquireShared返回正数时表示后续获取共享锁的请求也能满足,如果下一个节点正好也是获取共享锁,处理流程跟释放共享锁一致,所以直接调用doReleaseShared,释放刚刚获取的锁,唤醒下一个线程,让它也有机会获取共享锁。

6, 释放共享锁


释放共享锁

先尝试释放共享锁

释放共享锁

释放共享锁成功之后,唤醒想一个非cancel的后继节点,让它有机会获得锁。


AQS内部类ConditionObject实现了wait/notify的condition variable。也是基于双链表队列。

7, 实现notify

signal

类似Object#notify,调用之前必须先获得Object的固有锁

doSignal

把等待队列中的第一个节点挪到同步队列

从等待队列挪到同步队列

挪到同步队列之后,把前置节点的waitStatus置为Node.SIGNAL,确保当前节点有机会被唤醒以获得锁,如果当前节点没机会被唤醒,那就直接唤醒它。

8, 实现notifyAll

遍历双链表队列,挨个调用transferForSignal挪到同步队列

9, 实现wait

await

await参考Linux condition variable的语义,与Object#wait一样,调用之前必须先获取condition variable关联的锁,await时先加入等待队列等待signal,然后释放锁,然后检查是否收到了signal被挪到了同步队列,如果还没收到signal,暂停线程,等待收到signal加入同步队列之后,在同步队列的前置线程release时唤醒。线程被打断或收到了signal之后,再次获取锁,使得调用await的线程可以继续执行。

补一个wait的常用套路:

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

推荐阅读更多精彩内容