[Java EE] 多线程(四):线程安全问题(下)

server/2024/9/24 8:02:17/

1.5 volatile关键字

我们在了解这个关键字之前,我们首先要把产生线程安全的第4个原因补齐,我们来说说由于内存可见性引起的线程安全问题.
我们来看下面这样一段代码:

java">import java.util.Scanner;public class Demo16 {public static int count = 0;public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(() -> {while (count == 0) {;}System.out.println("count的值被修改");});Thread thread1 = new Thread(()->{Scanner scanner = new Scanner(System.in);count = scanner.nextInt();});thread.start();Thread.sleep(1000);thread1.start();}
}

由上述代码的逻辑,我们预期的结果是:在控制台的地方输入了一个不为0的数字的时候,上面的循环条件不满足,跳出循环,打印"count的值被修改",但是我们运行起来发现:
在这里插入图片描述
输入了不为0的值之后,毛都没有!!
为什么会出现这种情况呢?我们首先要了解一下Java中的内存模型(JMM),即Java虚拟机规范中定义的Java内存模型.
在这里插入图片描述
设计这种内存模型的目的就是为了保证:屏蔽掉各种硬件和操作系统的访问差异,避免由于操作系统不同和硬件结构的不同而引起的不兼容,真正做到"一次编译,到处运行".

  • 线程之间的共享变量存在主内存(Main Memory).(硬件角度总真正的内存空间)
  • 每⼀个线程都有自己的"⼯作内存"(Working Memory).(硬件角度的CPU中的寄存器)
  • 线程想要读取一个共享变量的时候,需要先从主内存中拷贝到工作内存中.
  • 线程想要修改一个共享变量的时候,先修改工作内存中的副本,再同步回主内存中.

但是当计算机发现每次从主内存中拷贝数据到工作内存中时,每次拷贝的数据都是一样的,而且工作内存的访问要比主内存的访问快好几个数量级,这就使得计算机不得不做出优化操作,每次读取变量的时候,把拷贝这一步优化掉了,直接读取的是工作内存中的数据,这就使得在另一个线程在主内存中修改这个共享变量的时候,另一个线程读取不到,也就无法改变工作内存中的数据.
但是我们在循环中加上一个print操作的时候,我们会惊奇地发现,循环可以停下来了:

java">import java.util.Scanner;
public class Demo17 {public static int count = 0;public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(() -> {while (count == 0) {System.out.println("tread");//IO输出比count判断慢得多}System.out.println("count的值被修改");});Thread thread1 = new Thread(()->{Scanner scanner = new Scanner(System.in);count = scanner.nextInt();});thread.start();Thread.sleep(1000);thread1.start();}
}

在这里插入图片描述
这又是为什么呢?是因为由于拷贝操作时内存方面的操作,速度肯定又要比IO操作快好几个数量级.而IO操作每次执行的结果注定是不同的,这就使得JVM不可以优化掉IO操作,即然IO操作都优化不到,比他快好几个数量级的拷贝操作肯定优化不到.

举例说明:年会不能停
有请助教:潘妮,马杰克,胡建林,杰弗瑞.
假如现在没有胡建林,现在潘妮就相当于主内存与工作内存中的拷贝操作,马杰克就相当于直接从工作内存中读取的操作.如今杰弗瑞要裁员,由于马杰克的工作效率和工作能力比潘妮大上好几个数量级,裁员的时候优先裁的就是潘妮,但是现在歪打正着混进个胡建林,就相当于IO操作,由于胡建林是靠着"关系"进入的众和集团,即使胡建林干活再慢,也不可以裁掉,即然比潘妮干活慢的胡建林都裁不掉,何谈裁潘妮.
在这里插入图片描述

现在如果没有IO操作,还想要while循环停下来,我们就可以引入volatile关键字来对变量进行修饰.告诉JVM,该变量必须每次都到主内存中读取,不可以进行优化操作,就相当于告诉老板,裁员的时候请不要裁到大动脉!!!

java">import java.util.Scanner;public class Demo18 {public static volatile int count = 0;//使用volatile告诉编译器该变量不可优化public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(() -> {while (count == 0) {;}System.out.println("count的值被修改");});Thread thread1 = new Thread(()->{Scanner scanner = new Scanner(System.in);count = scanner.nextInt();});thread.start();Thread.sleep(1000);thread1.start();}
}

在这里插入图片描述
但是我们需要注意的是:volatile不保证原子性

java">public class Demo21 {public static volatile int count = 0;public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(()->{for (int i = 0; i < 50000; i++) {count++;}});Thread thread1 = new Thread(()->{for (int i = 0; i < 50000; i++) {count++;}});thread.start();thread1.start();thread.join();thread1.join();System.out.println(count);}
}

在这里插入图片描述
我们看到,即使给count变量加了volatile关键字,还是会存在线程安全问题.

1.6 wait与notify–>线程的等待通知机制

由于线程之间是抢占式执行的,因此线程之间执行的先后顺序难以预知.
但是实际开发中有时候我们希望合理的协调多个线程之间的执行先后顺序.

举例说明:光与影
有请助教:黑子哲也,青峰大辉,火神大我
在与漂亮国的对决中,他们像拿到一个二分球,就先需要大辉先抢球,之后传球给黑子,黑子通过回旋一击,使得篮球改变运动轨迹,之后通过大我的扣篮完成完美一击.
他们中间的先后顺序,但凡慢了一步,或者是快了一步,都会丢失这2分.
在这里插入图片描述
在这里插入图片描述

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

  • wait()/wait(time):让线程进入等待状态
  • notify()/notifyAll():唤醒在当前对象上等待的所有线程
    注意:这几个方法都是Object类的方法

1.6.1 wait()方法

wait做的事情:

  • 释放当前对象的锁
  • 使得当前线程进入阻塞等待状态
  • 满足一定条件被唤醒之后,尝试重新获取锁
    注意:wait要搭配synchronized使用,否者在wait()方法解锁的时候,找不到对应的锁,就会抛出异常.
    wait结束等待的条件:
  • 其他线程使用调用notify方法唤醒该线程.
  • wait时间超时.
  • 其他线程调用该线程的interrupted方法,导致线程被强制唤醒,抛出异常.

1.6.2 notify()方法

notify⽅法是唤醒等待的线程.
• ⽅法notify()也要在同步⽅法或同步块中调⽤，该⽅法是⽤来通知那些可能等待该对象的对象锁的其它线程，对其发出通知notify，并使它们重新获取该对象的对象锁。
• 如果有多个线程等待，则有线程调度器随机挑选出⼀个呈wait状态的线程。(并没有"先来后到")
• 在notify()⽅法后，当前线程不会⻢上释放该对象锁，要等到执⾏notify()⽅法的线程将程序执⾏
完，也就是退出同步代码块之后才会释放对象锁。
使用示例:

java">public class Demo19 {public static void main(String[] args) throws InterruptedException {Object object = new Object();Thread thread = new Thread(()->{synchronized (object){System.out.println("等待开始");try {object.wait();//1.解锁,此时tread1才可以加锁 2.阻塞等待 3.唤醒之后再尝试获取锁 4.唤醒之后tread1未解除锁,阻塞} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("等待结束");//所以等待结束的打印一定在唤醒结束之后}});Thread thread1 = new Thread(()->{synchronized (object){System.out.println("唤醒开始");object.notify();System.out.println("唤醒结束");}});thread.start();Thread.sleep(1000);thread1.start();}
}

注意：在tread启动之后，必须sleep1s，由于线程调度的随机性，不加的话很可能先调度tread1现成，这样notify就会被wait错过

1.6.3 notifyAll()方法

上述notify方法只能随机唤醒一个线程:

java">public class Demo20 {public static void main(String[] args) throws InterruptedException {Object object = new Object();Thread thread = new Thread(()->{synchronized (object){System.out.println("等待开始");try {object.wait();//1.解锁,此时tread1才可以加锁 2.阻塞等待 3.唤醒之后再尝试获取锁 4.唤醒之后tread1未解除锁,阻塞} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("等待结束");//所以等待结束的打印一定在唤醒结束之后}});Thread thread2 = new Thread(()->{synchronized (object){System.out.println("等待开始1");try {object.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("等待结束1");}});Thread thread1 = new Thread(()->{synchronized (object){System.out.println("唤醒开始");object.notify();System.out.println("唤醒结束");}});thread.start();thread2.start();Thread.sleep(1000);thread1.start();}
}

运行结果:只唤醒了tread线程
在这里插入图片描述
如果想要一次性唤醒所有线程,就要用到notifyAll()方法:

java">public class Demo20 {public static void main(String[] args) throws InterruptedException {Object object = new Object();Thread thread = new Thread(()->{synchronized (object){System.out.println("等待开始");try {object.wait();//1.解锁,此时tread1才可以加锁 2.阻塞等待 3.唤醒之后再尝试获取锁 4.唤醒之后tread1未解除锁,阻塞} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("等待结束");//所以等待结束的打印一定在唤醒结束之后}});Thread thread2 = new Thread(()->{synchronized (object){System.out.println("等待开始1");try {object.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("等待结束1");}});Thread thread1 = new Thread(()->{synchronized (object){System.out.println("唤醒开始");object.notifyAll();System.out.println("唤醒结束");}});thread.start();thread2.start();Thread.sleep(1000);thread1.start();}
}

运行结果:线程全部被唤醒
在这里插入图片描述
在两个线程全部被唤醒之后,由于唤醒之后线程会尝试重新获取锁,tread和tread2还是会发生锁竞争.

举例:面试
有请助教:滑稽老铁
notify()方法:
在这里插入图片描述
notifyAll()方法:
在这里插入图片描述


http://www.ppmy.cn/server/20280.html

相关文章

docker简介

docker简介

Docker 是一种开源的容器化平台&#xff0c;用于打包、发布和运行应用程序及其依赖项。它基于 Linux 内核的 cgroups 和 namespaces 功能&#xff0c;实现了轻量级的虚拟化技术&#xff0c;使得开发人员能够在一个统一的环境中开发、测试和部署应用程序&#xff0c;同时也简化了…
阅读更多...
第67天：APP攻防-Frida反证书抓包移动安全系统资产提取评估扫描

第67天：APP攻防-Frida反证书抓包移动安全系统资产提取评估扫描

思维导图 案例一&#xff1a;内在-资产提取-AppinfoScanne AppinfoScanner 一款适用于以 HW 行动/红队/渗透测试团队为场景的移动端(Android、iOS、WEB、H5、静态网站)信息收集扫描工具&#xff0c;可以帮助渗透测试工程师、攻击队成员、红队成员快速收集到移动端或者静态 WEB …
阅读更多...
C语言入门课程学习笔记1

C语言入门课程学习笔记1

C语言入门课程学习笔记1 第1课 - 概论第2课 -helloworld第3课 -数据输出第4课 -数据类型与变量第5课 - 深入数据类型与变量第6课 - 类型与变量编程练习第7课 - 程序中的数据输入 本文学习自狄泰软件学院 唐佐林老师的 C语言入门课程&#xff0c;图片全部来源于课程PPT&#xff…
阅读更多...
linux如何正确使用三种后台运行命令 （注意“命令 “）

linux如何正确使用三种后台运行命令 （注意“命令 “）

linux 后台运行的命令是什么 在 Linux 中&#xff0c;可以使用以下几种方式将命令放到后台运行&#xff1a; 使用 & 符号&#xff1a;在命令行输入命令之后&#xff0c;可以使用 & 符号将其放到后台运行。例如&#xff0c;运行以下命令&#xff1a; $ command &…
阅读更多...
基于Spring Boot的旅游管理系统设计与实现

基于Spring Boot的旅游管理系统设计与实现

基于Spring Boot的旅游管理系统设计与实现 开发语言&#xff1a;Java框架&#xff1a;springbootJDK版本&#xff1a;JDK1.8数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/idea 系统部分展示 前台浏览管理界面图&#xff0c;通过内容列表可以获取网…
阅读更多...
2024年度铜川市科技计划申报类别方向、时间方式和要求

2024年度铜川市科技计划申报类别方向、时间方式和要求

一、征集范围 铜川市2024年度科技计划项目共设置三大类&#xff1a; &#xff08;一&#xff09;重点研发计划 围绕工业、农业、社会发展三大领域&#xff0c;主要支持产业链关键环节、薄弱环节的科技创新&#xff1b;企业共性技术、关键技术研究攻关&#xff1b;经济效益和…
阅读更多...
unity cinemachine相机 （案例 跟随角色移动）

unity cinemachine相机 （案例 跟随角色移动）

安装相机包 打开包管理工具 在 unity registry 搜索cinemachine 会在maincamera中生成一个组件cinemachineBrain 只能通过虚拟相机操控 主相机 虚拟相机的参数 案例 1.固定相机效果 位置 在固定的地方 默认的模式 2.相机跟随人物效果 焦距设置 20 跟随设置 把playere…
阅读更多...
TCP/IP网络模型

TCP/IP网络模型

应用层 应用层服务于用户&#xff0c;比如说我们在电脑上使用的软件&#xff0c;都是在应用层上实现的&#xff0c;当不同设备通信时&#xff0c;数据由下一层的传输层实现。应用层提供的功能比如HTTP、FTP、Telnet、DNS、SMTP等。应用层是工作在操作系统中的用户态&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023