【JavaEE精炼宝库】多线程(4)深度理解死锁、内存可见性、volatile关键字、wait、notify

目录

一、死锁

1.1 出现死锁的常见场景:

1.2 产生死锁的后果:

1.3 如何避免死锁:

二、内存可见性

2.1 由内存可见性产生的经典案例:

2.2 volatile 关键字:

2.2.1 volatile 用法:

2.2.2 volatile 不保证原子性:

2.2.3 volatile 作用总结:

三、wait 和 notify

3.1 wait 详解:

3.2 notify 和 notifyAll:

3.2.1 notify:

3.2.2 notifyAll:

3.3 面试题:wait 和 sleep 的区别:


在上一篇文章,我们了解了什么是线程安全,分析了产生线程不安全的原因。今天我们就要深度刨析一下线程不安全的经典案例:死锁和内存可见性引起的线程不安全问题。

一、死锁

1.1 出现死锁的常见场景:

• 场景一:

锁是不可重入锁(synchronized 是可重入锁),并且一个线程针对一个锁对象,连续加锁两次。

• 场景二:

两个线程两把锁。先让两个线程分别拿到一把锁,然后再去尝试获取对方的锁,这时就出现了死锁的情况。

• 场景三:

多个线程,多把锁。随着线程和锁的数目的增加,情况就会变得更加复杂,死锁就更容易出现。下面就是一个经典的死锁场景:哲学家就餐(除非吃到面条,否则不会放下筷子)。

 如果出现极端的情况,同一时刻所有的哲学家都拿起左边的筷子,这时就会出现死锁。

1.2 产生死锁的后果:

死锁是非常严重的问题。一个进程中线程的个数是有限的,死锁会使线程被卡住,没法继续工作。更加严重的是,死锁这种 bug 往往都是概率性出现(未知才是最可怕的)。测试的时候,怎么测试都没事,一旦发布,就出现了问题。更加要命的是发布也没有问题,等到夜深人静的时候,大家都睡着的时候,突然给你来点问题,直接带走年终奖😭。

1.3 如何避免死锁:

要想避免死锁,我们就要从产生死锁的原因入手。

教科书上经典的产生死锁的四个必要条件(下面给出的四个条件,友友们一定要背下来,面试的经典问题)。

1. 锁具有互斥性:

这时锁的基本特点,一个线程拿到锁之后,其他线程就得阻塞等待。

2. 锁具有不可抢占性(不可剥夺性):

一个线程拿到锁之后,除非他自己主动释放锁,否则谁也抢不走。

3. 请求和保持:

一个线程拿到一把锁之后,不释放这个锁的前提下,再尝试获取其他锁。

4. 循环等待。

多个线程获取多个锁的过程中,出现了循环等待,A 等待 B ,B 又等待 A。

在任何一个死锁的场景,都必须同时具备上述四点,只要缺少一个,都不会构成死锁。观察上面的四个条件不难发现条件 1 和条件 2 是锁的基本特性,这个我们无法改变,观察到条件 3 和条件 4 都是代码结构的问题,所以我们就从条件 3,4 入手。

• 针对条件 3:

不要让锁嵌套获取即可。如果有些场景必须要嵌套获取锁,那么就破除循环等待(条件 4 ),即使出现嵌套,也不会出现死锁。

• 针对条件 4:

当代码中,确实需要用到多个线程获取多把锁,一定要记得约定好加锁的顺序(每个线程都必须要先获取 A 锁,再获取 B 锁,再.......),就可以有效避免死锁了。

二、内存可见性

2.1 由内存可见性产生的经典案例:

请友友们观察一下下面这段代码,可以粘贴到自己的编译器上跑一下,看看是否符合你的预期。

public class demo1 {
    static int count = 0;
    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            while(count == 0){

            }
            System.out.println("t1.end");
        });
        Thread t2 = new Thread(() -> {
            Scanner in = new Scanner(System.in);
            System.out.println("请输入一个数字:");
            count = in.nextInt();
        });
        t1.start();
        t2.start();
    }
}

因为输入数据存在 IO 操作(很慢)所以一定能保证在我们输入数据的时候,t1 线程已经开始执行了。

正常来说,我们输入一个非 0 的数字后,t1 线程里面就会停止循环。但是产生的结果如下:

循环并没有退出,由于是前台线程,所以程序不能够结束。

上述问题产生的原因就是因为内存可见性

• 案例解析:

上面的案例产生的问题是由于编译器优化 / JVM 优化产生的问题。不是说优化不好,而是 JVM 在这种情况下的优化太激进了。为什么会产生这么激进的优化呢?

我们站在指令的角度来理解有两个方面:

1. 在while 循环体中,每次条件判断的时候,分为两个步骤:1. load:从内存读取数据到 cpu 寄存器。2. cmp:比较,条件成立就会继续执行。 当前循环的旋转速度很快,短时间内出现大量的 load 和 cmp 反复执行的效果,由于 load 执行消耗的时间比 cmp 消耗的时间多很多(量级是几千倍,上万倍)。

2. JVM 发现每次 load 执行的结果是一样的(在 t2 修改之前)。

于是 JVM 就把上述的 load 操作优化掉了,只有第一次是真正的进行 load 后续的 load 就直接读取刚才 load 在寄存器中的值,也就是说不会去内存中去读取值了,这时即使内存中的值已经修改,但是还是 load 不到,这就是我们的线程可见性问题。

其实在这里加上打印,程序就符合我们的预期了。

这是为什么呢?答:因为此时 IO 操作才是程序运行时间的大头,优化 load 就没有必要了,因为程序的瓶颈不是 load 。此外,IO 操作是不能被优化掉的,被优化的前提是反复执行的结果是相同的,IO 操作注定是反复执行的结果是不相同的。

• 小结:

上述问题的本质还是编译器优化引起的,优化掉 load 操作之后,使 t2 线程的修改,没有被 t1 线程感知到,这就是 ”内存可见性“ 问题。

2.2 volatile 关键字:

2.2.1 volatile 用法:

编译器到底啥时候优化这也是个 ”玄学问题“。我们作为程序员显然不希望看到这样的代码出现,因此 Java 就引入的 volatile 关键字,就可以解决内存可见性引起的问题。volatile 修饰的变量,能够保证 "内存可见性"。

代码在写入 volatile 修饰的变量的时候:

• 改变线程工作内存中 volatile 变量副本的值。

• 将改变后的副本的值从工作内存刷新到主内存。

代码在读取 volatile 修饰的变量的时候:

• 从主内存中读取 volatile 变量的最新值到线程的工作内存中。

• 从工作内存中读取 volatile 变量的副本。

前面我们讨论内存可见性时说了,直接访问工作内存(实际是 CPU 的寄存器或者 CPU 的缓存),速度非常快,但是可能出现数据不一致的情况。加上 volatile ,强制读写内存。速度是慢了,但是数据变的更准确了。

使用案例演示:

public class demo2 {
    public volatile static int count = 0;
    public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            System.out.println("t start");
            while(count == 0){

            }
            System.out.println("t end");
        });
        Thread t2 = new Thread(() -> {
            Scanner in = new Scanner(System.in);
            System.out.println("请输入一个数字:");
            count = in.nextInt();
        });
        t1.start();
        t2.start();
    }
}

案例效果:

2.2.2 volatile 不保证原子性:

volatile 和 synchronized 有着本质的区别。synchronized 能够保证原子性,volatile 保证的是内存可见性。例如下面这个案例:

public class demo3 {
    public volatile static int count = 0;
    public static void main(String[] args) {
        Object locker = new Object();
        Thread t1 = new Thread(() -> {
            for(int i = 0;i < 50000;i++){
//                synchronized(locker){
                    count++;
//                }

            }
        });
        Thread t2 = new Thread(() -> {
            for(int i = 0;i < 50000;i++){
//                synchronized(locker){
                    count++;
//                }
            }
        });
        t1.start();
        t2.start();
        try {
            t1.join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        try {
            t2.join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println(count);
    }
}

案例演示效果如下:

可以看到最终的结果还是不符合我们的预期,所以 volatile 不保证原子性。 

2.2.3 volatile 作用总结:

volatile 关键字的作用主要有如下两个:

• 保证内存可见性:

基于屏障指令实现,即当一个线程修改一个共享变量时,另外一个线程能读到这个修改的值。

• 保证有序性:

禁止指令重排序。编译时 JVM 编译器遵循内存屏障的约束,运行时靠屏障指令组织指令顺序。

注意:volatile 不能保证原子性。

三、wait 和 notify

由于线程之间是抢占式执行的,因此线程之间执行的先后顺序难以预知。但是实际开发中有时候我们希望合理的协调多个线程之间的执行先后顺序。就好像足球队一样,线程 1 要先传球,线程 2 才能射门。

针对随即调度,我们程序员也是有手段干预的,即通过 “等待” 的方式,能够让线程一定程度的按照我们预期的顺序来执行。无法主动让某个线程被调度,但是可以主动让某个线程等待(给别的线程机会)。

完成这个协调工作,主要涉及到三个方法:

注意:  wait,notify,notifyAll 都是 Object 类的方法(意味着所有类都可以)。

3.1 wait 详解:

wait 做的事:

• 使当前执行代码的线程进行等待(把线程放到等待队列中)。

• 释放当前的锁(wait 必须要放在锁的代码块里面使用)。

• 满足一定条件时被唤醒,重新尝试获取这个锁。

wait 结束等待的条件:

• 其他线程调用该对象的 notify 方法。

• wait 等待时间超时(wait 方法提供一个带有 timeout 参数的版本,来指定等待时间)。

• 其他线程调用该等待线程的 interrupted 方法,导致 wait 抛出 InterruptedException 异常。

注意:wait 和 sleep 一样会被线程的 interrupt 打断,wait 也会自动清空标志位。

案例演示如下:

public class demo1 {
    public static void main(String[] args) {
        Object locker = new Object();
        Thread t1 = new Thread(() -> {
            System.out.println("开始");
            try {
                synchronized(locker){
                    locker.wait();
                }

            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            System.out.println("结束");

        });
        t1.start();
    }
}

案例演示效果如下:

可以发现线程成功被停止了。 

注意:

wait 要搭配 synchronized 来使用。脱离 synchronized 使用 wait 会直接抛出异常。例如我们将上面的那段代码进行修改,将 locker 脱离锁,产生的情况如下:

这样在执行到 object.wait() 之后就一直等待下去,那么程序肯定不能⼀直这么等待下去了。这个时候就需要使用到了另外⼀个方法唤醒的方法 notify()。

3.2 notify 和 notifyAll:

3.2.1 notify:

notify 方法是唤醒等待的线程。具体作用如下:

• 方法 notify() 也要在同步方法或同步块中调用,该方法是用来通知那些可能等待该对象的对象锁的其它线程,对其发出通知 notify,并使它们重新获取该对象的对象锁。

• 如果有多个线程等待,则有线程调度器随机挑选出⼀个呈 wait 状态的线程。(并没有 "先来后到") 。

• 在 notify() 方法后,当前线程不会马上释放该对象锁,要等到执行 notify() 方法的线程将程序执行完,也就是退出同步代码块之后才会释放对象锁。

案例演示如下:

public class demo2 {
    public static void main(String[] args) {
        Object locker = new Object();
        Thread t1 = new Thread(() -> {
            System.out.println("开始等待");
            synchronized(locker){
                try {
                    locker.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("结束等待");
        });
        Thread t2 = new Thread(() -> {
            Scanner in = new Scanner(System.in);
            System.out.print("输入内容开始通知:");
            in.next();
            synchronized(locker){
                locker.notify();
                System.out.println("通知结束");
            }
        });
        t1.start();
        t2.start();
    }
}

案例演示效果如下:

3.2.2 notifyAll:

notify 只能随机唤醒一个由 wait 导致的等待线程,例如:

import java.util.*;
public class demo3 {
    public static void main(String[] args) {
        Object locker = new Object();
        Thread t1 = new Thread(() -> {
            System.out.println("t1:开始等待");
            synchronized(locker){
                try {
                    locker.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("t1:结束等待");
        });
        Thread t2 = new Thread(() -> {
            System.out.println("t2:开始等待");
            synchronized(locker){
                try {
                    locker.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("t2:结束等待");
        });
        Thread t3 = new Thread(() -> {
            Scanner in = new Scanner(System.in);
            System.out.print("输入内容开始通知:");
            in.next();
            synchronized(locker){
                locker.notify();
                System.out.println("通知结束");
            }
        });
        t1.start();
        t2.start();
        t3.start();
    }
}

最终跑出的结果如下:

可以清楚的看到只有一个线程被唤醒了。

因此 Java 引入 notifyAll 来一次性唤醒全部。我们就直接将上述代码稍加修改即可。

import java.util.*;
public class demo3 {
    public static void main(String[] args) {
        Object locker = new Object();
        Thread t1 = new Thread(() -> {
            System.out.println("t1:开始等待");
            synchronized(locker){
                try {
                    locker.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("t1:结束等待");
        });
        Thread t2 = new Thread(() -> {
            System.out.println("t2:开始等待");
            synchronized(locker){
                try {
                    locker.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("t2:结束等待");
        });
        Thread t3 = new Thread(() -> {
            Scanner in = new Scanner(System.in);
            System.out.print("输入内容开始通知:");
            in.next();
            synchronized(locker){
                locker.notifyAll();//修改处
                System.out.println("通知结束");
            }
        });
        t1.start();
        t2.start();
        t3.start();
    }
}

案例的演示效果如下:

可以看到我们所有等待的线程都被唤醒了。

注意:虽然是同时唤醒 2 个线程,但是这 2 个线程需要竞争锁,所以并不是同时执行,而仍然是有先有后的执行。

3.3 面试题:wait 和 sleep 的区别:

• wait:用于线程之间的通信。

• sleep:让线程阻塞一段时间。

相同点:是都可以让线程放弃执行一段时间。

大体的区别分为如下 3 点:

(1)wait 需要搭配 synchronized 使用,而 sleep 不需要。

(2)wait 是 Object 的方法,sleep 是 Thread 的静态方法。

(3)(从状态来) wait 被调用后,当前线程进入 waiting 状态并释放锁,并可以通过 notify 和 notifyAll 方法进行唤醒。sleep 被调用后当前线程进入 TIMED_WAITING 状态,不涉及锁相关的操作。

结语:

其实写博客不仅仅是为了教大家,同时这也有利于我巩固知识点,和做一个学习的总结,由于作者水平有限,对文章有任何问题还请指出,非常感谢。如果大家有所收获的话还请不要吝啬你们的点赞收藏和关注,这可以激励我写出更加优秀的文章。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/687153.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

C++中的stack和queue

C中的stack和queue 一丶stack1. stack的介绍2. stack的使用3. stack的模拟实现 二丶queue1. queue的介绍2. queue的使用3. queue的模拟实现 一丶stack 1. stack的介绍 stack的文档介绍 关于stack&#xff1a; 1. stack是一种容器适配器&#xff0c;专门用在具有后进先出操作的…

ROS socketcan_bridge使用说明

ROS socketcan_bridge使用说明&#xff08;以ubuntu20.04为例&#xff09; socketcan_bridge是什么 ROS针对socketcan提供了三个层次的驱动库&#xff0c;分别是ros_canopen&#xff0c;socketcan_bridge和socketcan_interface。 socketcan_interface&#xff1a; 功能&#x…

20240607在Toybrick的TB-RK3588开发板的Android12下适配IMX415摄像头和ov50c40

20240607在Toybrick的TB-RK3588开发板的Android12下适配IMX415摄像头和ov50c40 2024/6/7 11:42 【4K/8K摄像头发热量巨大&#xff0c;请做好散热措施&#xff0c;最好使用散热片鼓风机模式&#xff01;】 结论&#xff1a;欢迎您入坑。 Toybrick的TB-RK3588开发板的技术支持不…

STM32—按键控制LED(定时器)

目录 1 、 电路构成及原理图 2 、编写实现代码 main.c exit.c 3、代码讲解 4、烧录到开发板调试、验证代码 5、检验效果 此笔记基于朗峰 STM32F103 系列全集成开发板的记录。 1 、 电路构成及原理图 EXTI&#xff08;External interrupt/event controller&#xff…

机器视觉——物块分拣

项目进行到第四天&#xff0c;我们学到了很多&#xff0c;可以进行实操。 首先我们利用相机软件进行采图 然后导入代码里面 完整代码 dev_get_window (WindowHandle) list_image_files (采图, default, [], ImageFiles) for Index : 0 to |ImageFiles| - 1 by 1read_image (Im…

上BFT,是你的首选

上BFT&#xff0c;是你的首选 如果你想要找最智能的机器人&#xff0c;想要找品牌最全或者想要咨询专业的解决方案&#xff0c;一定不要错过BFT机器人采购站。BFT致力于为广大用户提供品质卓越、技术先进的机器人产品。 BFT里面机器人多种多样&#xff0c;不管您是想要工业机器…

取证工作: SysTools MailXaminer, 用强大功能辅助电子邮件调查工作的每一步

天津鸿萌科贸发展有限公司是 SysTools 系列软件的授权代理商。 SysTools MailXaminer 电子邮件取证软件将调查工作分为五个阶段&#xff1a;邮件加载、预览、搜索、分析及导出。软件对调查工作的每一阶段都提供了现代高级功能&#xff0c;以帮助数字取证调查员根据其具体要求对…

知乎知+广告推广开户充值的返点政策是怎样?

如何让您的品牌精准触达目标受众&#xff0c;实现高效传播与转化&#xff0c;成为了每一位市场人面临的挑战。为此&#xff0c;云衔科技作为业界领先的数字营销解决方案提供商&#xff0c;正式宣布全面支持知乎知广告开户及一站式代运营服务&#xff0c;旨在帮助各行业客户在知…

珠海鸿瑞毛利率持续下滑:核心产品销量大降,偿债能力偏弱

《港湾商业观察》黄懿 日前&#xff0c;珠海市鸿瑞信息技术股份有限公司&#xff08;下称“珠海鸿瑞”&#xff09;收到了北京证券交易所发出的第三轮审核问询函。 此前&#xff0c;2020年11月&#xff0c;珠海鸿瑞曾向深交所报送上市申请。IPO申请文件获受理后&#xff0c;珠…

用互斥锁解决缓存击穿

我先说一下正常的业务流程&#xff1a;需要查询店铺数据&#xff0c;我们会先从redis中查询&#xff0c;判断是否能命中&#xff0c;若命中说明redis中有需要的数据就直接返回&#xff1b;没有命中就需要去mysql数据库查询&#xff0c;在数据库中查到了就返回数据并把该数据存入…

pypi 发布自己的包

注册pypi个人用户 网址&#xff1a;https://pypi.org 目录结构dingtalk_utils 必须-pkgs- __init__.py .gitignore LICENSE 必须 README.md 必须 requirements.txt setup.py 必须安装依赖 pip install setuptools wheel安装上传工具 pip install twinesetup.py i…

Maxkb玩转大语言模型

Maxkb玩转大语言模型 随着国外大语言模型llama3的发布&#xff0c;搭建本地个人免费“人工智能”变得越来越简单&#xff0c;今天博主分享使用Max搭建本地的个人聊天式对话及个人本地知识域的搭建。 1.安装Maxkb开源应用 github docker快速安装 docker run -d --namemaxkb -p 8…

进入某个页面时将VUE中的某个Button按钮设置为选中状态

进入某个页面时将VUE中的某个Button按钮设置为选中状态 我想达到的效果如标题所说&#xff0c;目的是为了表示页面展示的内容是由于该按钮被选择的结果。 解决思路是使用VUE中的mounted()钩子函数&#xff0c;在该函数中调用按钮得到焦点方法、按钮被点击方法。具体代码如下&am…

Redis限流方案

限流简介 限流算法在分布式领域是一个经常被提起的话题&#xff0c;当系统的处理能力有限时&#xff0c;如何阻止计划外的请求继续对系统施压&#xff0c;是一个需要重视的问题。 除了控制流量&#xff0c;限流还有一个应用目的是用于控制用户行为&#xff0c;避免垃圾请求&a…

【echarts】如何制作,横坐标每个日期点如何对应一条竖线的图,以及 markline设置后不生效问题

图的样式如下&#xff1a; 在线演示 每一个日期&#xff0c;对应一条竖线展示。 echarts配置内容&#xff1a; 在线演示 option {xAxis: {type: category,data: [20240601, 20240602, 20240603, 20240604, 20240605, 20240606, 20240607] // X轴数据},yAxis: {type: valu…

Bond 网卡绑定技术学习

前言&#xff1a; 为了实现网卡的高可用性&#xff0c;需要学习一下 Bond技术 1. 概念 Bond&#xff08;也被称为链路聚合、端口绑定或接口绑定&#xff09;是一种网络技术&#xff0c;用于将多个物理网络接口&#xff08;如以太网接口&#xff09;组合成一个逻辑接口。这样做…

今日份动态规划学习

主要只搞了一个这道题&#xff0c;有点摸鱼了今天晚上&#xff0c;也是来小看一下这道题吧01背包完全背包 P1941 [NOIP2014 提高组] 飞扬的小鸟 题意&#xff1a; 这题是说&#xff0c;给我们一个游戏界面&#xff0c;界面的长度为n&#xff08;水平距离&#xff09;&#x…

E: Unable to locate package ros-kinetic-usb-cam

mkdir -p USB/src && cd USB/src catkin_init_workspace git clone https://github.com/bosch-ros-pkg/usb_cam.git cd .. catkin_make source devel/setup.bash echo "source ~/USB/devel/setup.bash" >> ~/.bashrc source ~/.bashrc 编译过程报错&…

Wireshark抓包日常运维实用过滤

0x0 Wireshark 介绍 Wireshark 是一款功能强大的网络分析工具&#xff0c;适用于网络专业人员。它提供了出色的过滤器&#xff0c;您可以轻松放大到您认为可能存在问题的位置。过滤器的主要好处是消除定位流量&#xff0c;并缩小要查找的数据类型。 0x1 根据源 IP 地址过滤主…

Golang | Leetcode Golang题解之第134题加油站

题目&#xff1a; 题解&#xff1a; func canCompleteCircuit(gas []int, cost []int) int {for i, n : 0, len(gas); i < n; {sumOfGas, sumOfCost, cnt : 0, 0, 0for cnt < n {j : (i cnt) % nsumOfGas gas[j]sumOfCost cost[j]if sumOfCost > sumOfGas {break}…