Java并发编程实战
王宝令
资深架构师
立即订阅
15151 人已学习
课程目录
已完结 50 讲
0/4登录后,你可以任选4讲全文学习。
开篇词 (1讲)
开篇词 | 你为什么需要学习并发编程?
免费
学习攻略 (1讲)
学习攻略 | 如何才能学好并发编程?
第一部分:并发理论基础 (13讲)
01 | 可见性、原子性和有序性问题:并发编程Bug的源头
02 | Java内存模型:看Java如何解决可见性和有序性问题
03 | 互斥锁(上):解决原子性问题
04 | 互斥锁(下):如何用一把锁保护多个资源?
05 | 一不小心就死锁了,怎么办?
06 | 用“等待-通知”机制优化循环等待
07 | 安全性、活跃性以及性能问题
08 | 管程:并发编程的万能钥匙
09 | Java线程(上):Java线程的生命周期
10 | Java线程(中):创建多少线程才是合适的?
11 | Java线程(下):为什么局部变量是线程安全的?
12 | 如何用面向对象思想写好并发程序?
13 | 理论基础模块热点问题答疑
第二部分:并发工具类 (14讲)
14 | Lock和Condition(上):隐藏在并发包中的管程
15 | Lock和Condition(下):Dubbo如何用管程实现异步转同步?
16 | Semaphore:如何快速实现一个限流器?
17 | ReadWriteLock:如何快速实现一个完备的缓存?
18 | StampedLock:有没有比读写锁更快的锁?
19 | CountDownLatch和CyclicBarrier:如何让多线程步调一致?
20 | 并发容器:都有哪些“坑”需要我们填?
21 | 原子类:无锁工具类的典范
22 | Executor与线程池:如何创建正确的线程池?
23 | Future:如何用多线程实现最优的“烧水泡茶”程序?
24 | CompletableFuture:异步编程没那么难
25 | CompletionService:如何批量执行异步任务?
26 | Fork/Join:单机版的MapReduce
27 | 并发工具类模块热点问题答疑
第三部分:并发设计模式 (10讲)
28 | Immutability模式:如何利用不变性解决并发问题?
29 | Copy-on-Write模式:不是延时策略的COW
30 | 线程本地存储模式:没有共享,就没有伤害
31 | Guarded Suspension模式:等待唤醒机制的规范实现
32 | Balking模式:再谈线程安全的单例模式
33 | Thread-Per-Message模式:最简单实用的分工方法
34 | Worker Thread模式:如何避免重复创建线程?
35 | 两阶段终止模式:如何优雅地终止线程?
36 | 生产者-消费者模式:用流水线思想提高效率
37 | 设计模式模块热点问题答疑
第四部分:案例分析 (4讲)
38 | 案例分析(一):高性能限流器Guava RateLimiter
39 | 案例分析(二):高性能网络应用框架Netty
40 | 案例分析(三):高性能队列Disruptor
41 | 案例分析(四):高性能数据库连接池HiKariCP
第五部分:其他并发模型 (4讲)
42 | Actor模型:面向对象原生的并发模型
43 | 软件事务内存:借鉴数据库的并发经验
44 | 协程:更轻量级的线程
45 | CSP模型:Golang的主力队员
结束语 (1讲)
结束语 | 十年之后,初心依旧
用户故事 (2讲)
用户来信 | 真好,面试考到这些并发编程,我都答对了!
3 个用户来信 | 打开一个新的并发世界
Java并发编程实战
登录|注册

08 | 管程:并发编程的万能钥匙

王宝令 2019-03-16
并发编程这个技术领域已经发展了半个世纪了,相关的理论和技术纷繁复杂。那有没有一种核心技术可以很方便地解决我们的并发问题呢?这个问题如果让我选择,我一定会选择管程技术。Java 语言在 1.5 之前,提供的唯一的并发原语就是管程,而且 1.5 之后提供的 SDK 并发包,也是以管程技术为基础的。除此之外,C/C++、C# 等高级语言也都支持管程。
可以这么说,管程就是一把解决并发问题的万能钥匙。

什么是管程

不知道你是否曾思考过这个问题:为什么 Java 在 1.5 之前仅仅提供了 synchronized 关键字及 wait()、notify()、notifyAll() 这三个看似从天而降的方法?在刚接触 Java 的时候,我以为它会提供信号量这种编程原语,因为操作系统原理课程告诉我,用信号量能解决所有并发问题,结果我发现不是。后来我找到了原因:Java 采用的是管程技术,synchronized 关键字及 wait()、notify()、notifyAll() 这三个方法都是管程的组成部分。而管程和信号量是等价的,所谓等价指的是用管程能够实现信号量,也能用信号量实现管程。但是管程更容易使用,所以 Java 选择了管程。
管程,对应的英文是 Monitor,很多 Java 领域的同学都喜欢将其翻译成“监视器”,这是直译。操作系统领域一般都翻译成“管程”,这个是意译,而我自己也更倾向于使用“管程”。
取消
完成
0/1000字
划线
笔记
复制
© 版权归极客邦科技所有,未经许可不得传播售卖。 页面已增加防盗追踪,如有侵权极客邦将依法追究其法律责任。
该试读文章来自付费专栏《Java并发编程实战》,如需阅读全部文章,
请订阅文章所属专栏。
立即订阅
登录 后留言

精选留言(128)

  • Hour
    今天又用代码验证了下,终于明白为啥用while了!

    当线程被唤醒后,是从wait命令后开始执行的(不是从头开始执行该方法,这点上老师的示意图容易让人产生歧义),而执行时间点往往跟唤醒时间点不一致,所以条件变量此时不一定满足了,所以通过while循环可以再验证,而if条件却做不到,它只能从wait命令后开始执行,所以要用while

    百看不一练😂😂😂😂
    2019-03-22
    4
    63
  • 密码123456
    有hasen 是执行完,再去唤醒另外一个线程。能够保证线程的执行。hoare,是中断当前线程,唤醒另外一个线程,执行玩再去唤醒,也能够保证完成。而mesa是进入等待队列,不一定有机会能够执行。

    作者回复: 我觉得你真的理解了!!!!

    2019-03-16
    4
    57
  • 三圆
    看了三遍,终于明白了管程MESA模型了,刚开始一直在想线程T1执行出队是什么意思?到底是哪个队列,是入口等待队列,还是条件等待队列,后来理解了都不是。这个队列应该理解为JDK里面的阻塞队列,里面存在的是共享数据,线程T1,T2分别去操作里面的共享数据,执行数据的入队,出队操作,当然这些操作是阻塞操作。当线程T1对阻塞队列执行数据出队操作时,进入管程,发现阻塞队列为空,此时线程T1进入阻塞队列不为空这个条件的条件等待队列,此时,其他线程还是可以进入管程的,比如T2进来了,对阻塞队列执行数据插入操作,这时就会致使线程T1从条件等待队列出来,进入入口等待队列,准备再一次进入管程……至于wait方法的参数,还是有必要的,因为可能线程需要的条件可能一直无法满足!

    作者回复: 例子选的不好,让你误解了...

    2019-03-16
    6
    49
  • Geek_be4cec
    本节说的可能并不好。该篇我看了三遍也没能完全看懂,于是自己搜索java管程相关的技术文章,才大致对管程有了个认知,总结如下:
    1.管程是一种概念,任何语言都可以通用。
    2.在java中,每个加锁的对象都绑定着一个管程(监视器)
    3.线程访问加锁对象,就是去拥有一个监视器的过程。如一个病人去门诊室看医生,医生是共享资源,门锁锁定医生,病人去看医生,就是访问医生这个共享资源,门诊室其实是监视器(管程)。
    4.所有线程访问共享资源,都需要先拥有监视器。就像所有病人看病都需要先拥有进入门诊室的资格。
    5.监视器至少有两个等待队列。一个是进入监视器的等待队列一个是条件变量对应的等待队列。后者可以有多个。就像一个病人进入门诊室诊断后,需要去验血,那么它需要去抽血室排队等待。另外一个病人心脏不舒服,需要去拍胸片,去拍摄室等待。
    6.监视器要求的条件满足后,位于条件变量下等待的线程需要重新在门诊室门外排队,等待进入监视器。就像抽血的那位,抽完后,拿到了化验单,然后,重新回到门诊室等待,然后进入看病,然后退出,医生通知下一位进入。

    总结起来就是,管程就是一个对象监视器。任何线程想要访问该资源,就要排队进入监控范围。进入之后,接受检查,不符合条件,则要继续等待,直到被通知,然后继续进入监视器。

    作者回复: 👍

    2019-08-01
    27
  • linqw
    管程的组成锁和0或者多个条件变量,java用两种方式实现了管程①synchronized+wait、notify、notifyAll②lock+内部的condition,第一种只支持一个条件变量,即wait,调用wait时会将其加到等待队列中,被notify时,会随机通知一个线程加到获取锁的等待队列中,第二种相对第一种condition支持中断和增加了时间的等待,lock需要自己进行加锁解锁,更加灵活,两个都是可重入锁,但是lock支持公平和非公平锁,synchronized支持非公平锁,老师,不知道理解的对不对

    作者回复: 总结很全面!

    2019-04-07
    22
  • 白马居士
    第一次看到MESA管程模型的时候很膈应,为什么要满足队列不空才能出队,在对照了《Java并发编程艺术》后,现在再看这一章才意识到“队列不空”只是人为的设置的条件A,只是为了说明管程支持多条件控制并发而自己设置控制条件的一个特例,是自己的设置,具体是什么与模型无关;初次看到这段还以为是MESA管程模型规定了“队列不空”这个出队条件,所以特别混乱。
    2019-04-05
    20
  • Hour
    老师,针对条件变量的while循环,还是不太理解,您说是范式,那它一定是为了解决特定的场景而强烈推荐的,也有评论说是为了解决虚假唤醒,但唤醒后,不也是从条件的等待队列进入到入口的等待队列,抢到锁后,重新进行条件变量的判断,用if完全可以啊,为什么必须是while,并且是范式?

    望老师赐教!

    作者回复: code1;
    if (条件不满足)
      wait()
    code2;

    当调用wait()时,阻塞。被唤醒时,就直接执行code2了,没机会重新判断。

    2019-03-22
    14
  • CCC
    MESA模型和其他两种模型相比可以实现更好的公平性,因为唤醒只是把你放到队列里而不保证你一定可以执行,最后能不能执行还是要看你自己可不可以抢得到执行权也就是入口,其他两种模型是显式地唤醒,有点内定的意思了。

    作者回复: 内定都出来了,真是理论联系生活

    2019-03-17
    1
    14
  • 佑儿
    老师,您好,结合第六讲,我的理解是:简单来说,一个锁实际上对应两个队列,一个是就绪队列,对应本节的入口等待队列,一个是阻塞队列,实际对应本节的条件变量等待队列,wait操作是把当前线程放入条件变量的等待队列中,而notifyall是将条件变量等待队列中的所有线程唤醒到就绪队列(入口等待队列)中,实际上哪个线程执行由jvm操作,我这样的理解对吗?

    作者回复: 对

    2019-03-20
    2
    10
  • 虎虎❤️
    重新回答思考题,问题变成wait的timeout参数是否必要。

    在MESA模型中,线程T1被唤醒,从条件A的等待队列中(其实是一个set,list的话可能会重复)移除,并加入入口等待队列,重新与其他的线程竞争锁的控制权。那么有这样一种可能,线程T1的优先级比较低,并且经常地有高优先级的线程加入入口等待队列。每次当它获得锁的时候,条件已经不满足了(被高优先级的线程抢先破坏了条件)。即使T1可以得到调度,但是也没办法继续执行下去。

    最后T1被饿死了(有点冷。。。)

    另外我刚才的问题想通了。不需要实现像lock一样的条件对象,并调用condition.await(). Synchronized用判断条件+wait()就可以了。

    作者回复: 我觉得你已经能把管程的运作在大脑里演绎出来了!

    2019-03-16
    10
  • 小李子
    wait() 不加超时参数,相当于得一直等着别人叫你去门口排队,加了超时参数,相当于等一段时间,再没人叫的话,我就受不了自己去门口排队了,这样就诊的机会会大一点,是这样理解吧?

    作者回复: 挺形象,就诊机会不一定大,但是能避免没人叫的时候傻等

    2019-04-05
    8
  • Handongyang
    感谢老师的精彩分享,谈一下个人对信号量和管程的理解。

    信号量机制是可以解决同步/互斥的问题的,但是信号量的操作分散在各个进程或线程中,不方便进行管理,因每次需调用PV操作,还可能导致死锁或破坏互斥请求的问题。

    管程是定义了一个数据结构和能为并发所执行的一组操作,这组操作能够进行同步和改变管程中的数据。这相当于对临界资源的同步操作都集中进行管理,凡是要访问临界资源的进程或线程,都必须先通过管程,由管程的这套机制来实现多进程或线程对同一个临界资源的互斥访问和使用。管程的同步主要通过condition类型的变量(条件变量),条件变量可执行操作wait()和signal()。管程一般是由语言编译器进行封装,体现出OOP中的封装思想,也如老师所讲的,管程模型和面向对象高度契合的。

    作者回复: 是的,管程只是一种解决并发问题的模型而已。

    2019-03-16
    8
  • 英耀
    王老师您好,我想请问一下文章中提到的是三种管程模型“hasen,hoare,mesa”是在什么资料(书籍、论文)中提到的呢?我想再深入了解这些管程模型的思想和原理,希望老师可以答疑解惑,感谢。

    作者回复: https://en.wikipedia.org/wiki/Monitor_(synchronization) 这个比较全面

    2019-04-27
    5
  • 红衣闪闪亮晶晶
    老师,我能明白如果t1线程被唤醒后再次进入等待队列,但是可能再次走到条件变量那里再次因为条件不满足随后再次开始等待,所以需要增加超时,所以当我给wait加了超时,时间到了以后t1再次开始while中的判断,如果满足便自己回到入口等待队列?
    我这样理解对吗?

    作者回复: 如果没超时,A线程wait了,由于代码的bug,没有其他线程notify,就会导致A一直wait。增加超时之后,A线程可以自己来决定是否继续等待。这样代码的健壮性会更好

    2019-03-26
    5
  • 饮识止渴(Vilin)
    线程wait超时后,会重新被放入入口队列,去争取锁吗?

    作者回复: 会

    2019-05-13
    4
  • 江南豆沙包
    老师,有个疑问,文中说到的条件变量,假如 synchronized(instance){做一些事情},这样一段代码,程序实际运行过程中条件变量是什么呢

    作者回复: 没用到条件变量,只有调用wait和notify的时候才会用到

    2019-03-23
    4
  • 大圣
    管程提出的太突兀了,没有从理论上给管程一个明确的定义,导致本章晦涩难懂。管程是一个理念还是一个工具?是JVM既定的实现还是需要人为自己实现,很多人会误以为管程是一个工具,用“管程”就能解决多线程问题。
    2019-07-23
    2
    3
  • dingdongfm
    看了很多遍,终于看明白了。文章里都是在用一个阻塞队列来举例子,而这个阻塞队列跟monitor里的队列没有关系。说清楚些会更好理解。
    2019-06-28
    3
  • the geek
    这一章给我的感觉是,告诉我们MESA的模型,然后可以自己手动实现管程了,说白了,当synchronize不满足我的需求时,可以自己写代码实现管程,还有并发包下的一些工具类可以辅助实现。
    2019-04-24
    3
  • life is short, enjoy mor...
    好记性不如烂笔头
    管程定义:
    管理共享内存和操作共享内存的过程,令其支持并发。

    并发编程领域两大难题,互斥和同步。

    互斥如何保证:封装共享数据及其对应操作,每个操作任意时刻只允许一个线程执行。

    同步如何保证:使用MESA模型。

    MESA模型之前没接触过,只是能够按照老师的思路顺下来,还没有深刻的理解,希望老师在接下来的文章中,加深MESA的使用😄

    2019-03-23
    3
收起评论
99+
返回
顶部