【JavaEE精炼宝库】多线程(3)线程安全 | synchronized
目录
一、线程安全
1.1 经典线程不安全案例:
1.2 线程安全的概念:
1.3 线程不安全的原因:
1.3.1 案例刨析:
1.3.2 线程不安全的名词解释:
1.3.3 Java 内存模型 (JMM):
1.3.4 解决线程不安全问题:
二、synchronized 关键字
2.1 synchronized 的特性:
2.1.1 互斥:
2.1.2 可重入:
2.2 synchronized 使用示例:
2.2.1 修饰代码块:
2.2.2 直接修饰普通方法:
2.2.3 修饰静态方法:
2.3 Java 标准库中的线程安全类:
一、线程安全
1.1 经典线程不安全案例:
线程安全是多线程中最核心的部分,因此线程安全也是难点和面试的考点,可以说只要写多线程代码,基本上都会涉及到。下面我就举一个经典的线程不安全案例,友友们来观察一下线程不安全。(注意要把自增的次数写大一点,因为如果次数太小,线程 2 还没启动线程 1 就已经运行结束了,所以看不到线程不安全的情况)。
public class Main {private static int count = 0;public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {//对 count 变量进行自增 5w次for (int i = 0; i < 50000; i++) {count++;}});Thread t2 = new Thread(() -> {//对 count 变量进行自增 5w次for (int i = 0; i < 50000; i++) {count++;}});t1.start();t2.start();t1.join();t2.join();// 预期值为 10wSystem.out.println(count);}
}
案例的预期值应为 10w。
案例的结果如下:
如果友友们,把这个案例自己拿起来跑,会发现每次的运行的结果都有差异,不符合我们的预期,显然出现了线程不安全的问题。
1.2 线程安全的概念:
线程安全的确切定义是复杂的,但我们可以这样认为:如果在多线程环境下代码运行的结果是符合我们预期的,即在单线程环境应该的结果,则说这个程序是线程安全的。
1.3 线程不安全的原因:
1.3.1 案例刨析:
如果我们将上述的案例部分改为下面红色方框(可以解决问题,但不是一种好的方法,因为这样写就无法利用到多线程的优势,更优的方法在下面的 synchronized 中会详细介绍),那么运行的结果就符合我们的预期了。
其实就是把多线程并发执行改为串行执行。 那么我们就可以确定是因为多线程才导致出现这个现象。上面不安全案例的执行过程大致如下:()中的数字表示执行顺序。如果对工作内存和主内存不了解的话,在下面的 Java 内存模型中有解释。
之所以会出现少加 5 的情况是因为,两个线程在进行抢占式执行。
那么为什么多线程会出现这种现象呢?
线程调度是随机的,这是线程安全问题的罪魁祸首,随机调度使⼀个程序在多线程环境下,执行顺序存在很多的变数。程序猿必须保证在任意执行顺序下,代码都能正常工作。
1.3.2 线程不安全的名词解释:
• 原子性:
• 什么是原子性?
我们把⼀段代码想象成⼀个房间,每个线程就是要进入这个房间的人。如果没有任何机制保证,A进入房间之后,还没有出来,B 是不是也可以进入房间,打断 A 在房间里的隐私。这个就是不具备原子性。一条 Java 语句不一定是原子的,也不一定只是一条指令。比如我们刚才看到 count++,其实是由三步操作组成的:(1)从内存把数据读到 CPU。(2)进行数据更新。(3)把数据写回到 CPU。
• 不保证原子性会给多线程带来什么问题?
如果一个线程正在对一个变量操作,中途其他线程插入进来了,如果这个操作被打断了,结果就可能是错误的。(这点也和线程的抢占式调度密切相关。如果线程不是 "抢占" 的,就算没有原子性,也问题不大)。
• 可见性:
可见性指,一个线程对共享变量值的修改,能够及时地被其他线程看到。
• 指令重排序:
什么是代码重排序,假如:一段代码是这样的:(1)去前台取下 U 盘。(2)去教室写 10 分钟作业。(3)去前台取下快递。
如果是在单线程情况下,JVM、CPU指令集会对其进行优化,比如,按 1->3->2的方式执行,也是没问题,可以少跑一次前台。这种叫做指令重排序。
编译器对于指令重排序的前提是 "保持逻辑不发生变化"。这⼀点在单线程环境下比较容易判断,但是在多线程环境下就没那么容易了,多线程的代码执行复杂程度更高,编译器很难在编译阶段对代码的执行效果进行预测,因此激进的重排序很容易导致优化后的逻辑和之前不等价。重排序是一个比较复杂的话题,涉及到 CPU 以及编译器的一些底层工作原理,此处不做过多讨论。
1.3.3 Java 内存模型 (JMM):
Java 虚拟机规范中定义了 Java 内存模型。目的是屏蔽掉各种硬件和操作系统的内存访问差异,以实现让 Java 程序在各种平台下都能达到一致的并发效果。
• 线程之间的共享变量存在主内存(Main Memory)
• 每一个线程都有自己的 "工作内存" (Working Memory)
• 当线程要读取一个共享变量的时候,会先把变量从主内存拷贝到工作内存,再从工作内存读取数据。
• 当线程要修改一个共享变量的时候,也会先修改工作内存中的副本,再同步回主内存。
由于每个线程有自己的工作内存,这些工作内存中的内容相当于同一个共享变量的 "副本"。此时修改线程 1 的工作内存中的值,线程 2 的工作内存不一定会及时变化。
此时引入了两个问题:
• 为啥要整这么多内存?
实际并没有这么多 "内存"。这只是 Java 规范中的一个术语,是属于 "抽象" 的叫法。所谓的 "主内存" 才是真正硬件角度的 "内存"。而所谓的 "工作内存",则是指 CPU 的寄存器和高速缓存。
• 为啥要这么麻烦的拷来拷去?
因为 CPU 访问自身寄存器的速度以及高速缓存的速度,远远超过访问内存的速度(快了 3 - 4 个数量级,也就是几千倍,上万倍)。
那么接下来问题又来了,既然访问寄存器速度这么快,还要内存干啥?
答案就是一个字:贵。
1.3.4 解决线程不安全问题:
下面这几点是线程不安全问题的原因,友友们一定要记住。
1. 线程在系统中是随机调度的,抢占式执行的。(线程不安全的罪魁祸首,万恶之源)。
2. 当前代码中,多个线程同时修改同一个变量。
3. 线程针对变量的修改操作,不是“原子”的。
4. 内存可见性问题,引起的线程不安全。
5. 指令重排序,引起的线程不安全。
我们从原因入手,解决问题。
原因 1:我们无法干预,这是操作系统自己分配的,我们干预不了。
原因 2:是一个切入点,但是在 Java 中,这样的做法不是很普适(因为当前代码,就是要多线程修改同一个变量),只是针对一些特定场景是可以的。
原因 3:这是解决线程安全问题,最普适的方案。我们就从原因 3 入手。
我们可以通过一些操作,把上述一系列 “非原子” 的操作,打包成一个 “原子” 操作。就是下面要介绍的 synchronized 加锁操作。
下面给出的案例大家看看就行,关于 synchronized 后续会详细介绍。
public class Main {private static int count = 0;public static void main(String[] args) throws InterruptedException {Object lock = new Object();Thread t1 = new Thread(() -> {//对 count 变量进行自增 5w次for (int i = 0; i < 50000; i++) {synchronized(lock){count++;}}});Thread t2 = new Thread(() -> {//对 count 变量进行自增 5w次for (int i = 0; i < 50000; i++) {synchronized(lock){count++;}}});t1.start();t1.join();t2.start();t2.join();// 预期值为 10wSystem.out.println(count);}
}
案例结果:可以看到符合我们的预期值,说明线程不安全问题被成功解决。
二、synchronized 关键字
大家一定要去多练习一下 synchronized 的读法,和拼写。因为面试的时候,说出来要让面试官听得懂。注意:这是个 Java 的关键字。(注意不是方法,里面的功能是 JVM 内部实现的)。
利用 synchronized 我们就可以把花括号里面的非原子操作,打包成原子。从而不允许别的线程 “插队”。
2.1 synchronized 的特性:
2.1.1 互斥:
synchronized 会起到互斥效果,某个线程执行到某个对象的 synchronized 中时,其他线程如果也执行到同⼀个对象 synchronized 就会阻塞等待。
• 加锁:t1 加上锁之后,t2 也尝试进行加锁,就会阻塞等待(系统内核控制),在 Java 中就能看到 BLOCKED状态,进入 synchronized 修饰的代码块,相当于加锁。
• 解锁:直到 t1 解锁之后,t2 才有可能(可能还有别的线程也在等待)拿到锁,退出synchronized 修饰的代码块,相当于解锁。
synchronized 用的锁是存在 Java 对象头里的。
• 理解"阻塞等待":
针对每一把锁,操作系统内部都维护了一个等待队列。当这个锁被某个线程占有的时候,其他线程尝试进行加锁,就加不上了,就会阻塞等待,⼀直等到之前的线程解锁之后,由操作系统唤醒一个新的线程,再来获取到这个锁。
注意:
• 上一个线程解锁之后,下一个线程并不是立即就能获取到锁,而是要靠操作系统来 "唤醒"。这也就 是操作系统线程调度的一部分工作。
• 假设有 A B C 三个线程,线程 A 先获取到锁,然后 B 尝试获取锁,然后 C 再尝试获取锁,此时 B 和 C 都在阻塞队列中排队等待,但是当 A 释放锁之后,虽然 B 比 C 先来的,但是 B 不⼀定就能获取到锁,而是是和 C 重新竞争,并不遵守先来后到的规则。
synchronized的底层是使用操作系统的 mutex lock实现的。
2.1.2 可重入:
synchronized 同步块(花括号里面内容)对同一条线程来说是可重入的,不会出现自己把自己锁死的情况。
• 理解 "把自己锁死":
⼀个线程没有释放锁,然后又尝试再次对同一对象加锁。按照之前对于锁的设定,第二次加锁的时候,就会阻塞等待,直到第一次的锁被释放,才能获取到第二个锁,但是释放第⼀个锁也是由该线程来完成,结果这个线程已经躺平了,啥都不想干了,也就无法进行解锁操作。这时候就会死锁。
这样的锁称为:不可重入锁
Java 中的 synchronized 是可重入锁,因此没有上面的问题。
案例如下:
public class demo1 {public static void main(String[] args) {Object lock = new Object();Thread t = new Thread(() -> {synchronized(lock){synchronized(lock){System.out.println("hello t");}}System.out.println("t.end");});t.start();}
}
案列结果演示如下:
那么 synchronized 是如何完成可重入锁的这种机制呢?
在可重入锁的内部,包含了 "线程持有者" 和 "计数器" 两个信息。
• 如果某个线程加锁的时候,发现锁已经被人占用,但是恰好占用的正是自己,那么仍然可以继续获取到锁,并让计数器自增。
• 解锁的时候计数器递减为 0 的时候,才真正释放锁。(才能被别的线程获取到)
2.2 synchronized 使用示例:
在 Java 中任何一个对象都可以作为加锁的对象(Java 中特定独立的设定,其他语言中C++,Go,Python....)都是只有极少数特定的对象可以用来加锁。
synchronized 后面带上()里面就是写的 “锁对象”。
注意:
锁对象的用途,有且只有一个,就是用来区分两个线程是否是针对同一个对象加锁。如果是,就会出现锁竞争 / 锁冲突 / 互斥,就会引起阻塞等待。如果不是,就不会出现锁竞争,也就不会阻塞等待。和对象具体是啥类型,和它里面有啥属性,有啥方法,接下来是否要操作这个对象.....统统没有任何关系,不要自己脑补出其他的功能。
2.2.1 修饰代码块:
明确指定锁哪个对象。
• 锁任意对象:
我们前面所写的都是这种写法。
public class SynchronizedDemo {private Object locker = new Object();public void method() {synchronized (locker) {}}
}
• 锁当前对象:
public class SynchronizedDemo {public void method() {synchronized (this) {}}
}
2.2.2 直接修饰普通方法:
当加锁的生命周期和方法的生命周期,是一样的,这个时候,就可以直接把 synchronized 写到方法上。(可以和 public 位置互换)这个写法就相当于是一进入方法就针对 this 加锁。
锁的 SynchronizedDemo 对象 。
public class SynchronizedDemo {public synchronized void methond() {}
}
上面的这两种写法等价。
2.2.3 修饰静态方法:
锁的 SynchronizedDemo 类的对象(一个类可以有多个对象,但是只有一个类对象)
public class SynchronizedDemo {public synchronized static void method() {}
}
如果我们要把 synchronized 放到方法里面,但是 static 里面不能使用 this。如果使用会出现如下错误。
解决方法:我们可以利用反射来拿到类对象。
例如:
public class SynchronizedDemo {public static void method() {synchronized (Counter.class){}}
}
到这相信友友们就能理解上面利用 synchronized 解决线程不安全问题。
我们重点要理解,synchronized 锁的是什么。两个线程竞争同一把锁,才会产生阻塞等待。两个线程分别尝试获取两把不同的锁,不会产生竞争。
2.3 Java 标准库中的线程安全类:
Java 标准库中很多都是线程不安全的。这些类可能会涉及到多线程修改共享数据,又没有任何加锁措施。
例如:ArrayList、LinkedList、HashMap、TreeMap、HashSet、TreeSet、StringBuilder等。
但是还有一些是线程安全的,使用了一些锁机制来控制。
Vector(不推荐使用) 、HashTable (不推荐使用) 、ConcurrentHashMap 、 StringBuffer等。
还有的虽然没有加锁,但是不涉及 "修改",仍然是线程安全的。例如:String。
结语:
其实写博客不仅仅是为了教大家,同时这也有利于我巩固知识点,和做一个学习的总结,由于作者水平有限,对文章有任何问题还请指出,非常感谢。如果大家有所收获的话还请不要吝啬你们的点赞收藏和关注,这可以激励我写出更加优秀的文章。
相关文章:

【JavaEE精炼宝库】多线程(3)线程安全 | synchronized
目录 一、线程安全 1.1 经典线程不安全案例: 1.2 线程安全的概念: 1.3 线程不安全的原因: 1.3.1 案例刨析: 1.3.2 线程不安全的名词解释: 1.3.3 Java 内存模型 (JMM): 1.3.4 解决线程不安全问题: 二…...

el-table-column两种方法处理特殊字段,插槽和函数
问题:后端返回的字段为数字 解决办法: {{ row[item.prop] 1 ? "启用" : "禁用" }} {{ row[item.prop] }} 最终果: 另外:如果多种状态时可用函数 {{ getStatus(row[item.prop]) }} {{ row[item.prop…...

huggingface笔记: accelerate estimate-memory 命令
探索可用于某一机器的潜在模型时,了解模型的大小以及它是否适合当前显卡的内存是一个非常复杂的问题。为了缓解这个问题,Accelerate 提供了一个 命令行命令 accelerate estimate-memory。 accelerate estimate-memory {MODEL_NAME} --library_name {LIBR…...

李飞飞亲自撰文:大模型不存在主观感觉能力,多少亿参数都不行
近日,李飞飞连同斯坦福大学以人为本人工智能研究所 HAI 联合主任 John Etchemendy 教授联合撰写了一篇文章,文章对 AI 到底有没有感觉能力(sentient)进行了深入探讨。 「空间智能是人工智能拼图中的关键一环。」知名「AI 教母」李…...
超级好用的C++实用库之套接字
💡 需要该C实用库源码的大佬们,可搜索微信公众号“希望睿智”。添加关注后,输入消息“超级好用的C实用库”,即可获得源码的下载链接。 概述 C中的Socket编程是实现网络通信的基础,允许程序通过网络与其他程序交换数据。…...

C++ | Leetcode C++题解之第108题将有序数组转换为二叉搜索树
题目: 题解: class Solution { public:TreeNode* sortedArrayToBST(vector<int>& nums) {return helper(nums, 0, nums.size() - 1);}TreeNode* helper(vector<int>& nums, int left, int right) {if (left > right) {return nu…...
5月27日,每日信息差
第一、韩国宇宙航空厅于 5 月 27 日正式成立,旨在推动以民间为主的太空产业生态圈发展,助力韩国成为航天强国。首任厅长尹宁彬表示,该机构将在庆尚南道泗川市的临时大楼开展相关工作。 第二、京东集团宣布,自2024年7月1日起&…...

echart扩展插件词云echarts-wordcloud
echart扩展插件词云echarts-wordcloud 一、效果图二、主要代码 一、效果图 二、主要代码 // 安装插件 npm i echarts-wordcloud -Simport * as echarts from echarts; import echarts-wordcloud; //下载插件echarts-wordcloud import wordcloudBg from /components/wordcloudB…...
解决无法直接抓取链接地址
当我们在爬取一些文章列表的时候,可能无法从接口或者html界面上获取到文章的详细列表 这个时候我们可以通过模拟点击且重写window.open方法,将跳转的地址捕获,并且放到html中去。 这样我们就可以获取到某个文章的详细地址了 // 保存原始的 …...

java面对对象编程-多态
介绍 方法的多态 多态是在继承,重载,重写的基础上实现的 我们可以看看这个代码 package b;public class main_ {public static void main(String[] args) { // graduate granew graduate(); // gra.cry();//这个时候,子类的cry方法就重写…...

【Sql Server】随机查询一条表记录,并重重温回顾下自定义函数的封装和使用
大家好,我是全栈小5,欢迎来到《小5讲堂》。 这是《Sql Server》系列文章,每篇文章将以博主理解的角度展开讲解。 温馨提示:博主能力有限,理解水平有限,若有不对之处望指正! 目录 前言随机查询语…...

基于C#开发web网页管理系统模板流程-主界面管理员录入和编辑功能完善
前言 紧接上篇->基于C#开发web网页管理系统模板流程-登录界面和主界面_c#的网页编程-CSDN博客 已经完成了登录界面和主界面,本篇将完善主界面的管理员录入和编辑功能,事实上管理员录入和编辑的设计套路适用于所有静态表的录入和编辑 首先还是介绍一下…...

K8s证书过期处理
问题描述 本地有一个1master2worker的k8s集群,今天启动VMware虚拟机之后发现api-server没有起来,docker一直退出,这个集群是使用kubeadm安装的。 于是kubectl logs查看了日志,发现证书过期了 解决方案: 查看证书 #…...

刷题之路径总和Ⅲ(leetcode)
路径总和Ⅲ 这题和和《为K的数组》思路一致,也是用前缀表。 代码调试过,所以还加一部分用前序遍历数组和中序遍历数组构造二叉树的代码。 #include<vector> #include<unordered_map> #include<iostream> using namespace std; //Def…...
MongoDB 原子操作:确保数据一致性和完整性的关键
在 MongoDB 中,原子操作是指可以一次性、不可分割地执行的数据库操作。这些操作能够保证在多个并发操作中不会出现数据不一致或者丢失的情况,确保数据库的数据完整性和一致性。 基本语法 MongoDB 的原子操作通常与更新操作相关,其基本语法如…...
2024上半年软考高级系统架构设计师回顾
本博客地址:https://security.blog.csdn.net/article/details/139238685 2024年上半年软考在5月25-26日举行,趁着时间刚过去记忆还在,简单写一点总结。 关于考试形式:上机考试(以后也都是机考)࿰…...
SQL注入绕过技术深度解析与防御策略
引言 在Web安全领域,SQL注入攻击一直是一个棘手的问题。攻击者通过SQL注入手段获取敏感数据、执行恶意操作,甚至完全控制系统。尽管许多防御措施已被广泛采用,但攻击者仍不断开发新的绕过技术。本文将深度解析SQL注入的绕过技术,…...
Redis教程(十六):Redis的缓存穿透、缓存击穿、缓存雪崩
传送门:Redis教程汇总篇,让你从入门到精通 缓存穿透 描述 用户需要查询一个数据,例如要查一张ASSET_CODE 999999的卡片,查询redis中没有,就直接去请求数据库,数据库中也不存在对应的数据,返回…...
如何实现一个高效的单向链表逆序输出?
实现单向链表逆序输出的关键点有两个: 反转链表本身 遍历反转后的链表并输出首先,我们来看如何反转链表: class Node:def __init__(self, data):self.data dataself.next Nonedef reverse_list(head):"""反转单向链表"""prev Nonecurrent h…...
使用 Go 实现 HelloWorld 程序,并分析其结构
在学习任何新的编程语言时,编写一个 “Hello, World” 程序通常是最初的入门步骤。这不仅是一个传统,也是一种快速了解语言基本语法和运行机制的有效方法。对于 Go 语言,这个过程不仅可以帮助新手快速入门,还提供了一个窗口&#…...

【大模型RAG】拍照搜题技术架构速览:三层管道、两级检索、兜底大模型
摘要 拍照搜题系统采用“三层管道(多模态 OCR → 语义检索 → 答案渲染)、两级检索(倒排 BM25 向量 HNSW)并以大语言模型兜底”的整体框架: 多模态 OCR 层 将题目图片经过超分、去噪、倾斜校正后,分别用…...

【JavaEE】-- HTTP
1. HTTP是什么? HTTP(全称为"超文本传输协议")是一种应用非常广泛的应用层协议,HTTP是基于TCP协议的一种应用层协议。 应用层协议:是计算机网络协议栈中最高层的协议,它定义了运行在不同主机上…...
连锁超市冷库节能解决方案:如何实现超市降本增效
在连锁超市冷库运营中,高能耗、设备损耗快、人工管理低效等问题长期困扰企业。御控冷库节能解决方案通过智能控制化霜、按需化霜、实时监控、故障诊断、自动预警、远程控制开关六大核心技术,实现年省电费15%-60%,且不改动原有装备、安装快捷、…...

dedecms 织梦自定义表单留言增加ajax验证码功能
增加ajax功能模块,用户不点击提交按钮,只要输入框失去焦点,就会提前提示验证码是否正确。 一,模板上增加验证码 <input name"vdcode"id"vdcode" placeholder"请输入验证码" type"text&quo…...
汇编常见指令
汇编常见指令 一、数据传送指令 指令功能示例说明MOV数据传送MOV EAX, 10将立即数 10 送入 EAXMOV [EBX], EAX将 EAX 值存入 EBX 指向的内存LEA加载有效地址LEA EAX, [EBX4]将 EBX4 的地址存入 EAX(不访问内存)XCHG交换数据XCHG EAX, EBX交换 EAX 和 EB…...
MySQL用户和授权
开放MySQL白名单 可以通过iptables-save命令确认对应客户端ip是否可以访问MySQL服务: test: # iptables-save | grep 3306 -A mp_srv_whitelist -s 172.16.14.102/32 -p tcp -m tcp --dport 3306 -j ACCEPT -A mp_srv_whitelist -s 172.16.4.16/32 -p tcp -m tcp -…...

使用LangGraph和LangSmith构建多智能体人工智能系统
现在,通过组合几个较小的子智能体来创建一个强大的人工智能智能体正成为一种趋势。但这也带来了一些挑战,比如减少幻觉、管理对话流程、在测试期间留意智能体的工作方式、允许人工介入以及评估其性能。你需要进行大量的反复试验。 在这篇博客〔原作者&a…...

【从零学习JVM|第三篇】类的生命周期(高频面试题)
前言: 在Java编程中,类的生命周期是指类从被加载到内存中开始,到被卸载出内存为止的整个过程。了解类的生命周期对于理解Java程序的运行机制以及性能优化非常重要。本文会深入探寻类的生命周期,让读者对此有深刻印象。 目录 …...

uniapp 小程序 学习(一)
利用Hbuilder 创建项目 运行到内置浏览器看效果 下载微信小程序 安装到Hbuilder 下载地址 :开发者工具默认安装 设置服务端口号 在Hbuilder中设置微信小程序 配置 找到运行设置,将微信开发者工具放入到Hbuilder中, 打开后出现 如下 bug 解…...

02.运算符
目录 什么是运算符 算术运算符 1.基本四则运算符 2.增量运算符 3.自增/自减运算符 关系运算符 逻辑运算符 &&:逻辑与 ||:逻辑或 !:逻辑非 短路求值 位运算符 按位与&: 按位或 | 按位取反~ …...