【多线程】线程安全问题和解决方案

我们来看下面这一段代码

public class demo {public static void main(String[] args) throws InterruptedException {Cou count = new Cou();Thread t1 = new Thread(() -> {for (int i = 0; i < 10000; i++) {count.add();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 10000; i++) {count.add();}});t1.start();t2.start();t1.join();t2.join();System.out.println(Cou.count);}
}class Cou {static int count = 0;public void add() {count++;}
}

我们期望的结果是得到20000,但是实际上这个值是随机的,它一定是小于20000的。这就是线程安全带来的问题。

说到线程安全问题我们就要知道什么是原子性,我们举一个例子:我们把一段代码想象成一个房间,每个线程就是要进入这个房间的人。如果没有任何机制保证,A进入房间之后,还没有出来;B 是不是也可以进入房间,打断 A 在房间里的隐私。这个就是不具备原子性的。那我们应该如何解决这个问题呢?是不是只要给房间加一把锁,A 进去就把门锁上,其他人是不是就进不来了。这样就保证了这段代码的原子性了。有时也把这个现象叫做同步互斥,表示操作是互相排斥的。一条Java指令不一定是原子的,也不一定只是一条指令。比如我们上面代码的count++,其实是由三步操作组成的:①把cpu上的数据读取到寄存器中 ②修改数据 ③把修改的数据存到内存里。不保证原子性会给多线程带来很多问题,如果一共线程正在修改数据,这个时候另一个线程也开始操作相同点数据就会打断第一个线程的工作,这样结果就很有可能是有问题的。

可见性,就是一个线程修改变量能够及时被其他线程看到

我们来看下面的图
在这里插入图片描述

线程的调度是随机的,抢占式执行,这样就可能会导致执行顺序和逻辑出现问题,我们不知道有多少次自增是正确的,所以结果我们并不知道。

产生线程安全问题的原因

①操作系统中,线程调度的顺序是随机的,抢占式执行。

②两个线程针对同一个变量进行修改。

③修改操作不是原子的。

④内存可见性问题。

⑤指令重排序问题。

我们可以通过加锁来解决线程安全问题

谈到锁我们就要了解 synchronized 的特性,synchronized 会起到互斥效果,如果某个线程执行到某个对象的synchronized 中时其他线程也执行到同一个对象那么synchronized 就会阻塞等待

阻塞等待:针对每一把锁,操作系统内部都维护了一个等待队列。当这个锁被某个线程占有的时候,其他线程尝试进行加锁,就加不上了,就会阻塞等待,一直等到之前的线程解锁之后,由操作系统唤醒一个新的线程,再来获取到这个锁。

进入synchronized 修饰的代码块相当于加锁,退出synchronized 修饰的代码块相当于是解锁。

上一个线程解锁之后, 下一个线程并不是立即就能获取到锁. 而是要靠操作系统来 “唤醒”. 这也就是操作系统线程调度的一部分工作.假设有 A B C 三个线程, 线程 A 先获取到锁, 然后 B 尝试获取锁, 然后 C 再尝试获取锁, 此时 B和 C 都在阻塞队列中排队等待. 但是当 A 释放锁之后, 虽然 B 比 C 先来的, 但是 B 不一定就能获取到锁, 而是和 C 重新竞争, 并不遵守先来后到的规则 .

synchronized(lock){synchronized(lock){......}//2
}//1

我们假设第一次加锁成功,这个时候lock就属于是被锁定状态,再进行第二次加锁,这个时候应该是阻塞等待状态,要想加锁成功就需要等到锁释放后才能加锁成功。但是实际上一旦第二次加锁阻塞了就会出现死锁。要想第二次加锁成功就需要第一次加锁释放锁,第一次要想释放锁就需要执行到 1 的的位置,而执行到 1 的位置就需要第二次加锁成功,但是由于第二次加锁导致了阻塞,这样就没有办法执行到 1 ,也就无法释放锁。

synchronized 是可重入锁,就是一个线程针对一把锁连续加锁两次,不出现死锁,这种锁就是可重入锁。可以有效的解决上面死锁的问题。

在可重入锁的内部,包含了 “线程持有者” 和 “计数器” 两个信息。如果某个线程加锁的时候,发现锁已经被人占用,但是恰好占用的正是自己,那么仍然可以继续获取到锁,并让计数器自增。解锁的时候计数器递减为 0 的时候,才真正释放锁。(才能被别的线程获取到 )

造成死锁的四个必要条件

1.互斥作用(锁的基本特性):当一个线程加锁了,另一个线程想要获取这把锁就需要阻塞等待。

2.不可抢占(锁的基本特性):当锁被一个线程拿到后,另一个线程只能等这个线程释放锁后才能拿到这把锁,不能强行抢占。

3.请求保持(代码结构):一个线程尝试获取多把锁(拿到一把锁后还没有释放就想着获取另一把锁)。

4.循环等待/环路等待(代码结构):等待的依赖关系形成了环。

只有同时出现上述四种情况才会出现死锁。我们要想解决死锁,就需要避免上述四种情况同时出现,第一条和第二条是synchronized的特性,我们改变不了,所以只能避免三和四同时出现。对于三来所,避免编写锁嵌套逻辑并不好使,所以我们可以针对四来解决死锁。我们可以约定加锁的顺序,避免循环等待,我们可以针对锁进行编号,比如加多把锁的时候,先加编号小的锁,再加编号大的锁(所有线程都遵守)

我们来看下面的代码

public class Thread1 {private static int isQuit=0;public static void main(String[] args) {Thread t1 = new Thread(()->{while (isQuit==0){//循环什么都不做}System.out.println("t1退出");});Thread t2 = new Thread(()->{System.out.print("请输入isQuit:");Scanner scanner = new Scanner(System.in);//输入不为0则t1线程结束isQuit = scanner.nextInt();});t1.start();t2.start();}
}

在这里插入图片描述

我们预期结果应该是输入不为0则t1线程结束但是我们输入 1 t1线程并没有结,我们通过jconsole可以看到t1线程的状态是RUNNABLE正在执行。

在这里插入图片描述

这也是一个线程安全问题,之前我们是两个线程同时修改一个变量,这次是一个线程读一个线程修改,这种情况也有可能会有问题。这就是由内存可见性引起的。因为我们上面说过,load把isQuit的值读取到寄存器中,让后通过cmp指令判断是否为0,因为这个循环速度很快短时间内会进行大量的load和cmp操作,此时,编译器发现进行了这么多次load操作结果都是一样的并且load操作还很费时间,一次load相当于上万次cmp,所以编译器就做了一个大胆的决定,只在第一次循环的时候读取内存后续都不读取,只从寄存器中读取isQuit,这是编译器的自我优化,编译器的初衷是提升程序效率,但是提高程序效率的前提是逻辑不变,但是此时修改isQuit的操作是另一个线程操作的,编译器不能正确判断,以为isQuit没有修改,所以就引起了bug。而编译器什么时候会优化我们无法推断,所以我们可以用volatile 来告诉编译器不要优化,这样程序就不会出错。

public class Thread1 {private volatile static int isQuit=0;public static void main(String[] args) {Thread t1 = new Thread(()->{while (isQuit==0){//循环什么都不做}System.out.println("t1退出");});Thread t2 = new Thread(()->{System.out.print("请输入isQuit:");Scanner scanner = new Scanner(System.in);//输入不为0则t1线程结束isQuit = scanner.nextInt();});t1.start();t2.start();}
}

在这里插入图片描述

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

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

相关文章

【微信小程序】6天精准入门(第4天:自定义组件及案例界面)附源码

一、自定义组件 1、介绍 从小程序基础库版本 1.6.3 开始&#xff0c;小程序支持简洁的组件化编程。所有自定义组件相关特性都需要基础库版本 1.6.3 或更高。 开发者可以将页面内的功能模块抽象成自定义组件&#xff0c;以便在不同的页面中重复使用&#xff1b;也可以将复杂的页…

Linux 下安装配置部署MySql8.0

一 . 准备工作 MySQL安装包&#xff1a;在官网下载需要的版本&#xff0c;这里我用的版本是 MySQL 8.0.34 https://dev.mysql.com/downloads/mysql/ 本次linux机器使用的是阿里云ECS实例 二 . 开始部署 1. 将安装包上传至服务器 解压到当前文件夹 tar -zxvf mysql-8.0.34…

解决方法:从客户端(---<A href=“http://l...“)中检测到有潜在危险的 Request.Form 值。

从客户端(-----<A href"http://l...")中检测到有潜在危险的 Request.Form 值。 解决方法&#xff1a;应该是不同的.net Framework版本对代码的校验不同&#xff0c;造成在高版本操作系统&#xff08;即高.net Framework版本校验&#xff09;不兼容&#xff0c;可…

4 OpenCV实现多目三维重建(多张图片增量式生成稀疏点云)【附源码】

本文是基于 OpenCV4.80 进行的&#xff0c;关于环境的配置可能之后会单独说&#xff0c;先提一嘴 vcpkg 真好用 1 大致流程 从多张图片逐步生成稀疏点云&#xff0c;这个过程通常包括以下步骤&#xff1a; 初始重建&#xff1a; 初始两张图片的选择十分重要&#xff0c;这是整…

linux 安装操作 redis

1、redis概述和安装 1.1、安装redis 1. 下载redis 地址 https://download.redis.io/releases/ 2. 将 redis 安装包拷贝到 /opt/ 目录 3. 解压 tar -zvxf redis-6.2.1.tar.gz4. 安装gcc yum install gcc5. 进入目录 cd redis-6.2.16. 编译 make7. 执行 make install 进…

【Python生活脚本】视频转Gif动图

忘记过去&#xff0c;超越自己 ❤️ 博客主页 单片机菜鸟哥&#xff0c;一个野生非专业硬件IOT爱好者 ❤️❤️ 本篇创建记录 2023-10-20 ❤️❤️ 本篇更新记录 2023-10-20 ❤️&#x1f389; 欢迎关注 &#x1f50e;点赞 &#x1f44d;收藏 ⭐️留言&#x1f4dd;&#x1f64…

RHEL 8.6 Kubespray 1.23.0 install kubernetes v1.27.5

文章目录 1. 预备条件2. download01 节点 安装 dockerdownload01 节点 介质下载下载 bastion01节点配置 yum 源bastion01 节点安装 docker5. 安装 docker insecure registrybastion01 部署 nginx 与 镜像入库13.1 配置 config.sh13.2 配置 setup-docker.sh13.3 配置 start-ngin…

多测师肖sir_高级金牌讲师___ui自动化之selenium001

一、认识selenium &#xff08;1&#xff09;selenium是什么&#xff1f; a、selenium是python中的一个第三方库 b、Selenium是一个应用于web应用程序的测试工具&#xff0c;支持多平台&#xff0c;多浏览器&#xff0c;多语言去实现ui自动化测试&#xff0c;我们现在讲的Sel…

正点原子嵌入式linux驱动开发——Linux中断

不管是单片机裸机实验还是Linux下的驱动实验&#xff0c;中断都是频繁使用的功能&#xff0c;在裸机中使用中断需要做一大堆的工作&#xff0c;比如配置寄存器&#xff0c;使能IRQ等等。但是Linux内核提供了完善的中断框架&#xff0c;只需要申请中断&#xff0c;然后注册中断处…

Linux CentOS 8(网卡的配置与管理)

Linux CentOS 8&#xff08;网卡的配置与管理&#xff09; 目录 一、项目介绍二、命令行三、配置文件四、图形画界面的网卡IP配置4.1 方法一4.2 方法二 一、项目介绍 Linux服务器的网络配置是Linux系统管理的底层建筑&#xff0c;没有网络配置&#xff0c;服务器之间就不能相互…

接口测试 —— jmeter与数据库的操作

在进行接口测试时&#xff0c;数据库查询是常用的一种判断方式&#xff0c;用来确定数据操作是否成功。除了这种场景&#xff0c;数据库里面的数据也是非常好的测试数据&#xff0c;比如作为请求的测试数据输入&#xff0c;那使用jmeter工具如何把数据库的数据依次获取作为参数…

Win10下基于VS2015编译SQLite3源码

一、下载SQLite SQLite SQLite Download Page 下载红框部分的3个文件 提示&#xff1a;这里有个 sglite-autoconf-3420000.tar.gz 是免编译版&#xff0c;想省事就下载这个&#xff0c;但我自己用这个老是编译不过 所以我这里不推荐这个了 二、配置SQLite 打开vs 2015或者其他…

如何处理前端路由懒加载?

聚沙成塔每天进步一点点 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 欢迎来到前端入门之旅&#xff01;感兴趣的可以订阅本专栏哦&#xff01;这个专栏是为那些对Web开发感兴趣、刚刚踏入前端领域的朋友们量身打造的。无论你是完全的新手还是有一些基础的开发…

界面组件DevExpress WPF v23.1 - 全面升级文档处理功能

DevExpress WPF拥有120个控件和库&#xff0c;将帮助您交付满足甚至超出企业需求的高性能业务应用程序。通过DevExpress WPF能创建有着强大互动功能的XAML基础应用程序&#xff0c;这些应用程序专注于当代客户的需求和构建未来新一代支持触摸的解决方案。 无论是Office办公软件…

DETR原理与代码超详细解读

文章目录 前言一、DETR论文原理1、DETR整体介绍2、DETR论文贡献3、DETR模型框架4、DETR基于二分图匹配的LOSS 二、DETR环境安装1、安装基础环境2、pycocotools安装3、其它环境安装4、环境验证5、训练与推理效果显示 三、数据准备1、coco 数据格式2、修改数据 四、DETR加载数据代…

lnmp架构部署Discuz论坛并配置重定向转发

lnmp架构部署Discuz论坛并配置重定向转发 文章目录 lnmp架构部署Discuz论坛并配置重定向转发环境说明部署Discuz论坛系统下载Discuz论坛系统代码包&#xff0c;官网地址如下&#xff1a;部署Discuz论坛系统步骤&#xff1a;解压安装Discuz源码包配置虚拟主机进入Discuz安装界面…

ArcGIS笔记10_如何创建渔网?

本文目录 前言Step 1 确定渔网的精度单位Step 2 有底图时创建渔网的操作 前言 ArcGIS中的渔网是一个很好用的工具&#xff0c;它可以创建出规规整整的小格子&#xff0c;每个小格子都对应一个标注点&#xff0c;可以将原本散乱的数据规整化&#xff0c;如下图&#xff1a; Ste…

非平稳信号分析和处理、STFT的瞬时频率研究(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

Monocle 3 | 太牛了!单细胞必学R包!~(一)(预处理与降维聚类)

1写在前面 忙碌的一周结束了&#xff0c;终于迎来周末了。&#x1fae0; 这周的手术真的是做到崩溃&#xff0c;2天的手术都过点了。&#x1fae0; 真的希望有时间静下来思考一下。&#x1fae0; 最近的教程可能会陆续写一下Monocle 3&#xff0c;炙手可热啊&#xff0c;欢迎大…