【Java EE初阶三 】线程的状态与安全(下)

3. 线程安全

        线程安全某个代码,不管它是单个线程执行,还是多个线程执行,都不会产生bug,这个情况就成为“线程安全”。

        线程不安全某个代码,它单个线程执行,不会产生bug,但是多个线程执行,就会产生bug,这个情况就成为 “线程不安全”,或者 “存在线程安全问题”。     

        举个线程不安全例子,我们计算一个变量的自增次数,它循环了100000次,用两个线程去计算,各自计算循环50000次的次数。   

3.1 线程不安全样例

        根本原因:线程的随机调度,抢占式执行

        代码结构:不同线程修改同一数据

        直接原因:多线程操作不是原子的

        由于线程的随机调度,抢占式执行(不可避免),代码结构会促进该原因加剧不良后果

       1、代码一分析---->代码随机调度,抢占执行的例子

        代码如下:

public class ThreadDemo4 {private static int count = 0;public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {for (int i = 1; i < 50000; i++) {count++;}});Thread t2 = new Thread(() -> {for (int i = 50000; i <= 100000; i++) {count++;}});t1.start();t2.start();t1.join();t2.join();System.out.println("count: " + count);}
}

        按照我们的逻辑,从1自增到10_0000,肯定是自增了10_0000次,但是结果如下图所示:

      

        我们实际答案却不是10_0000,是53978次,其出现如上情况的最主原因就是多线程代码它们是并发执行的,且往代码深层次分析,java中的count++语句是由cpu的三个指令构成的:

1)首先load 从内存中读取数据到cpu的寄存器中;

(2)其次add 把寄存器中的值 + 1;

(3)最后save 把寄存器中的值写回到内存中;
        因为上面两个线程t1和t2是并发执行的,那则t1 和 t2 线程的执行顺序就是无序的,他们可能同时读取内存中的数据add,双方都自增完往寄存器+1(应该是+1后再+1),但是最后从寄存器中save到内存中时,却只读取了一个线程自增完后的数值,另外一个自增的过程被忽略了,一些具体的分析如下图所示;

        线程并发执行的结果是无数的,并不是简单的排列组合就能穷举出来,因为并发的原因,可能 t1 线程它执行了两次,才执行一次 t2 线程,或者 t2 执行的次数更多,t1 线程只执行一次。等以上这些情况都是有可能出现的。

        故此t1 和 t2自增的时候,就可能从寄存器中拿的是同一个值,这两线程的其中一个自增后,没有来得及在内存中进行自加1,另一个线程自增完后就直接往内存中那这个值了,最后的结果肯定是不符合我们预期的。

        故此由上图所示,符合我们预期的效果就只有最前面的两个情况了,但是这种情况也就是多线程串行化执行,执行完 t1,再执行t2,代码如下所示:

public class ThreadDemo4 {private static int count = 0;public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {for (int i = 1; i < 50000; i++) {count++;}});Thread t2 = new Thread(() -> {try {t1.join();} catch (InterruptedException e) {throw new RuntimeException(e);}for (int i = 50000; i <= 100000; i++) {count++;}});t1.start();t2.start();t2.join();System.out.println("count: " + count);}
}

        结果如下:

      

        但是如此操作的话,这个代码和多线程的运行就完全没有关系了;

       

        2、代码二分析---->内存可见性例子

        代码如下:

package thread;import java.util.Scanner;public class ThreadDemo22 {private static int flag = 1;public static void main(String[] args) {Thread t1 = new Thread(() -> {while (flag == 1) {System.out.println("这里是线程t1");}System.out.println("t1线程结束");});Thread t2 = new Thread(() -> {System.out.println("请输入flag的值");Scanner scanner = new Scanner(System.in);flag = scanner.nextInt();});t1.start();t2.start();}
}

        执行预期是当我们输入不等于1的值,就打印 “t1线程结束”,但是当我们输入结果为5,最终执行结果却不是我们预期的效果,执行结果如下:

        

        flag值是!=1,但是t1线程一直在循环运行,虽然t2线程是在按照我们的要求改变flag的值,为什么结果与预期是相悖的,如此就涉及到了jvm内部的优化了,和内存可见性相关;

        t1线程中的flag==1这一操作有两个核心指令:

(1)load,读取内存中的flag值到寄存器

(2)拿着寄存器中的值和1进行比较(条件跳转指令)

        这里load的每次操作取到的值都是一样的,而当我们执行scanner操作修改flag的值时,load这一指令,已经执行上百亿次了;且从内存中取数据这一操作是非常耗时的,远远比条件跳转指令花时间,这时由于load开销太大,jvm就会产生怀疑,怀疑这个load继续操作的必要性;从而给出优化,把从内存读数据load这一操作给优化掉了,这样一来,jvm就不会再从内存中拿数据,而是把load拿到的值放到寄存器中,从寄存器拿到数据,进行比较。这样可以大幅度的提高循环的执行速度。

        上面的例子,t2修改了内存,但是t1没看到内存变化,就称为内存可见性问题。而内存可见性问题,是高度依赖编译器优化的问题;

 3.2 线程不安全问题解决方法

3.2.1  t1 循环里加sleep

        代码如下:

public class ThreadDemo3 {private static int flag = 1;public static void main(String[] args) {Thread t1 = new Thread(() -> {while (flag == 1) {try {Thread.sleep(10);} catch (InterruptedException e) {throw new RuntimeException(e);}//循环题里,啥也不写}System.out.println("t1线程结束");});Thread t2 = new Thread(() -> {System.out.println("请输入flag的值");Scanner scanner = new Scanner(System.in);flag = scanner.nextInt();});t1.start();t2.start();}
}

        结果如下:

        方法详解:因为10秒中都可以让t1线程里面的循环执行上百亿次(cpu飞快的从内存中网寄存器中读取数据),这样会导致load的开销就非常大,代码的优化迫切程度就比较大;但是加了sleep后,我们让线程t1进行休眠,如此load的开销就小了很多,代码的优化迫切程度就降低了,故此load就能将5这个值在优化前读取到寄存器和flag进行比较,最终达到我们预期的效果;

3.3.2 给flag变量加volatile修饰 

        代码如下:

public class ThreadDemo3 {private volatile static int flag = 1;public static void main(String[] args) {Thread t1 = new Thread(() -> {while (flag == 1) {//循环题里,啥也不写}System.out.println("t1线程结束");});Thread t2 = new Thread(() -> {System.out.println("请输入flag的值");Scanner scanner = new Scanner(System.in);flag = scanner.nextInt();});t1.start();t2.start();}
}

        结果与之前类似,略;

        方法分析:

1、java提供volatile关键字,其核心作用,就是保证 “内存可见性”另一功能:禁止指令重排序)可以使jvm强迫的优化强制关闭,这样就可以确保循环每次都是从内存中拿数据了,虽然这样执行效率也会下降,但数据更为准确了;

2、我们对编译器优化是这样表述的:

        编译器发现,每次循环都要从内存中读取数据,内存开销都太大了,于是把读取内存这一操作优化成读取寄存器这一操作。

        在JMM模型是这样描述的:

        编译器发现,每次循环都要从 “主内存” 中读取数据,就会把数据从 “主内存” 中复制下到 “工作内存” 中,后续每次读取都是在 “工作内容” 这读取。(这里的“工作内容代指cpu寄存器 + 缓存”)---->这里的 “主内存” 翻译成内存,“工作内存” 翻译成cpu寄存器 ;

3.3 线程不安全的原因

1、根本原因
        操作系统上的线程是“抢占式执行”,随机调度的
---->给线程之间的执行顺序带来了很多变数。

2、代码结构
        多个线程同时修改同一个变量。

    2.1、如果一个线程修改一个变量,没事。

    2.2、多个线程读取同一个变量,没事的-->如果只是读取,变量的内容是固定不变的。

    2.3、多个线程修改不同的变量,没事--->如果是两个不同的变量,彼此之间就不会产生相互覆盖的情况了

3、直接原因
        多线程修改操作,本身不是原子的

        即count++:该操作可以被细分为3个cpu指令,一个线程执行这些指令,执行到一半会被调走,从而给其他线程“可乘之机”------>每个cpu指令,都是原子的,要么不执行,要么执行完

4、内存可见性
        一个线程读,一个线程写,也会导致线程安全的问题。

5、指令重排序
        编译器的一种优化,在保证代码逻辑不变的情况下,将一些代码的指令重新排序,从而提高代码的执行效率,但是有时候会因为重排序后,多线程编程就会出现线程安全问题。

番外:

        String是一个不可变对象

好处:

  1. 方便jvm进行缓存(放到字符串常量池中)
  2. Hash值固定
  3. String的对象是线程安全的-à意味着只能读取,不能修改

为什么说string是不可变的?

  1. 持有的数据(char 【】数组)是private的
  2. 里面没有提供public的方法来修改char数组的相关内容。
  3. Final只是表示不可被继承,和可变没有关系。

3.4  针对上述原因给出的解决方案 

        针对原因1:
        我们无法给出解决方案,因为操作系统内部已经实现了“抢占式执行”,我们干预不了

        针对原因2:
        分情况,有的时候,代码结构可以调整,有的时候调整不了。

        针对原因3:
        把要修改的变量这操作,通过特殊手段,把这操作在系统里的多个指令打包成一个“整体”。例如加锁操作,而加锁的操作(下一篇详细讲解),就是把多个指令打包成一个原子的操作。

        针对原因4:
        可以对代码进行调整,避免内存可见性的问题;也可以使用volatile进行修饰,强制把代码优化关了,这样数据就更准确了,但执行效率也就变慢了。

        针对原因5:
        将某些可能会指令重排序的变量,加volatile修饰,强制取消指令重排序的优化。

ps:本次的内容就到这里了,如果感兴趣的话就请一键三连哦!!!

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[语音识别]开源语音识别faster-whisper模型下载地址

官方源码&#xff1a; https://github.com/SYSTRAN/faster-whisper 模型下载地址&#xff1a; large-v3模型&#xff1a;https://huggingface.co/Systran/faster-whisper-large-v3/tree/main large-v2模型&#xff1a;https://huggingface.co/guillaumekln/faster-whisper-l…

Pandas DataFrame重命名索引 index 键和值

重命名索引名(键) Pandas的索引是一个很重要的概念,Series和DataFrame都有索引,索引对象有很多方法和变量,这里列举了修改索引键值的几个例子。 直接复制 import pandasdf = pandas.DataFrame({A: [1, 2, 3],B: [

七:Day01_Java9—16新特性

第一章 JDK9 新特性 jdk9是新特性最多的&#xff0c;因为jdk8是一个稳定版本。 1、JDK9新特性概述 模块系统 &#xff08;Module System&#xff09; Java9最大特性。它提供了类似于OSGI框架的功能&#xff0c;模块之间存在相互的依赖关系&#xff0c;可以导出一个公共的API…

YOLOv8改进 | 2023注意力篇 | iRMB倒置残差块注意力机制(轻量化注意力机制)

一、本文介绍 本文给家大家带来的改进机制是iRMB&#xff0c;其是在论文Rethinking Mobile Block for Efficient Attention-based Models种提出&#xff0c;论文提出了一个新的主干网络EMO(后面我也会教大家如何使用该主干&#xff0c;本文先教大家使用该文中提出的注意力机制…

C++/Qt版酒店客房管理系统代码详解——入住管理模块

入住管理模块代码: ```cpp #include <QtWidgets> // 客房类 class Room {public: Room(int number) : m_number(number) {} int getNumber() const { return m_number; } private: int m_number; }; // 客房管理系统 class RoomManagementSystem : publi…

【Java进阶篇】什么是UUID,能不能保证唯一?

什么是UUID&#xff0c;能不能保证唯一? ✔️典型解析✔️优缺点 ✔️各个版本实现✔️V1.基于时间戳的UUID✔️V2.DCE(Distributed Computing Environment)安全的UUID✔️V3.基于名称空间的UUID(MD5)✔️V4.基于随机数的UUID✔️V5.基于名称空间的UUID(SHA1)✔️各个版本总结…

学生管理系统(vue + springboot)

学生管理系统&#xff08;vuespringboot&#xff09;资源-CSDN文库 项目介绍 这是一个采用前后端分离开发的项目&#xff0c;前端采用 Vue 开发、后端采用 Spring boot Mybatis 开发。 项目部署 ⭐️如果你有 docker 的话&#xff0c;直接 docker compose up 即可启动&#…

SpringBoot入门指南(学习笔记)

概述 Springboot是Spring的一个子项目&#xff0c;用于快速构建Spring应用程序 入门 ①创建SpringBoot工程 ②编写Controller RestController public class HelloContoller {RequestMapping("/hello")public String hello() {return "hello";} }③运行…

golang锁源码【只有关键逻辑】

条件锁 type Cond struct {L Lockernotify notifyList } type notifyList struct {wait uint32 //表示当前 Wait 的最大 ticket 值notify uint32 //表示目前已唤醒的 goroutine 的 ticket 的最大值lock uintptr // key field of the mutexhead unsafe.Pointer //链表头…

论文解读:Coordinate Attention for Efficient Mobile Network Design(CVPR2021)

论文前言 原理其实很简单&#xff0c;但是论文作者说得很抽象&#xff0c;时间紧的建议直接看3.1中原理简述CBMA、原理简述CBMA以及3.2中原理简述coordinate attention block即可。 Abstract 最近关于mobile network设计的研究已经证明了通道注意(例如&#xff0c;the Squee…

java中file类常用方法举例说明

java中file类常用方法举例说明 当使用 java.io.File 类时&#xff0c;以下是一些常用方法的举例说明&#xff1a; 创建文件或目录&#xff1a; // 使用路径名创建File实例 File file new File("C:\\Users\\UserName\\Documents\\example.txt");// 使用父路径和子路…

JAVA-ArrayList的相关坑

ArrayList的asList()方法 Arrays.asList()方法&#xff0c;本质是调用了Arrays的一个静态内部类&#xff0c;实现了AbstractList接口&#xff0c;这个方法是重写了AbstractList的方法&#xff0c;但是这个asList()大小是固定的&#xff0c;当我们使用add方法时会调用父类Abstr…

roslaunch格式

The roslaunch package comes with roslaunch tool as well as several support tools to assist in the process of launching ROS Nodes. 目录 roslaunch Launch syntaxPassing in argsNon-launch optionsInternal-use only optionsEnvironment Variables (advanced users)…

23. 一维数组

写在前面&#xff1a; 今天是2023年12月31日&#xff0c;也是整个2023年的最后一天。我在CSDN上只有短短几个月的时光&#xff0c;但非常感谢大家的支持&#xff0c;作为一名刚刚大一的大学生呢&#xff0c;学习编程&#xff0c;学习写博客是很重要的事&#xff0c;所以在新的…

翻页的电子画册如何制作

​在过去&#xff0c;一本精美的画册往往需要大量的人力物力去印刷、装帧、运输。而现在&#xff0c;只需一台电脑、一个网址和一个创意&#xff0c;就可以轻松制作出一本电子画册。这种变化不仅降低了成本&#xff0c;还带来了更多的便利性和灵活性。 首先&#xff0c;你需要选…

网络故障排查和流量分析利器-Tcpdump命令

Tcpdump是一个在Unix/Linux系统上广泛使用的命令行网络抓包工具。它能够捕获经过网络接口的数据包&#xff0c;并将其以可读的格式输出到终端或文件中。Tcpdump是一个强大的命令行工具&#xff0c;能够捕获和分析网络数据包&#xff0c;为网络管理员和安全专业人员提供了深入了…

【网络面试(6)】IP协议对网络包的转发

在前面的博客中&#xff0c;我们提到过&#xff0c;网络传输的报文是有真实的数据包和一些头部组成&#xff0c;目前我们了解的头部就有TCP头、IP头、MAC头&#xff0c;而且这三个头部信息都是在应用程序委托给协议栈之后&#xff0c;被写入的相关信息&#xff0c;这些头部都是…

Leetcode4-唯一元素的和(1748)

1、题目 &#xff08;1748&#xff09;给你一个整数数组 nums 。数组中唯一元素是那些只出现 恰好一次 的元素。 请你返回 nums 中唯一元素的 和 。 示例 1&#xff1a; 输入&#xff1a;nums [1,2,3,2] 输出&#xff1a;4 解释&#xff1a;唯一元素为 [1,3] &#xff0c;…

修改jenkins的目录(JENKINS_HOME)

默认JENKINS_HOME是/var/lib/jenkins/ 现要修改为/home/jenkins_data/jenkins 最开始 sudo cp -a /var/lib/jenkins/ /home/jenkins_data/ 然后如下操作&#xff1a; 1、首先 /etc/sysconfig/jenkins&#xff1a;jenkins配置文件&#xff0c;“端口”&#xff0c;“JENKIN…

9、python-闭包

简介 1.闭包&#xff0c;又称闭包函数或者闭合函数&#xff0c;其实和嵌套函数类似 2.不同之处在于&#xff0c;闭包中外部函数返回的不是一个具体的值&#xff0c;而是一个函数 3.一般情况下&#xff0c;返回的函数会赋值给一个变量&#xff0c;这个变量可以在后面被继续执行…