【Java】常见锁策略 CAS机制 锁优化策略

news2024/11/16 21:26:50

在这里插入图片描述

前言

在本文会详细介绍各种锁策略、CAS机制以及锁优化策略
不仅仅局限于Java,任何和锁相关的话题,都可能会涉及到下面的内容。
这些特性主要是给锁的实现者来参考的.
普通的程序猿也需要了解一些, 对于合理的使用锁也是有很大帮助的

文章目录

  • 前言
  • ✍一、常见的锁策略
    • 1.1乐观锁 悲观锁
    • 1.2重量级锁 轻量级锁
    • 1.3自旋锁 挂起等待锁
    • 1.4公平锁 非公平锁
    • 1.5可重入锁 不可重入锁
    • 1.6读写锁
  • ✍二、CAS机制
    • 2.1概念
    • 2.2如何实现?
    • 2.3有何应用?
      • ①实现原子类
      • ②实现自旋锁
    • 2.4锁的ABA问题
  • ✍三、锁优化策略
    • 3.1偏向锁
    • 3.2轻量级锁
    • 3.3自旋锁
    • 3.4其他锁优化
      • ①锁消除
      • ②锁粗化

✍一、常见的锁策略

1.1乐观锁 悲观锁

乐观锁:预测到程序中遇到冲突的可能性较小,从而消耗的资源(时间资源,内存资源)都比较少。
悲观锁:预测到程序中遇到冲突的可能性比较大,从而消耗的资源(时间资源,内存资源)比较多。

可以将悲观锁抽象理解为拥有被害妄想症

我们来画图再次具象的理解一下:

我们站在乐观锁的角度,认为程序中读数据的操作远远多于写数据的操作,所以在一般情况下,不会对程序进行加锁。
在这里插入图片描述

我们站在悲观锁的角度,认为程序中写操作远远多于读数据的操作,所以每次进行操作时就需要加锁。

在这里插入图片描述

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized既是乐观锁,也是悲观锁,拥有自适应机制
初始为乐观锁,当检测到程序中锁的竞争较大时,就会切换悲观锁。

1.2重量级锁 轻量级锁

我们先来理解一下资源在计算机中时如何操作的
在这里插入图片描述
重量级锁:

重量级锁过度依赖了操作系统提供的mutex(互斥锁),这种锁同步方式的消耗非常大,主要包括系统调度引起的用户态和内核态的切换,线程阻塞造成的线程调度问题

轻量级锁:

轻量级锁的加锁机制尽可能的不使用mutex,从而减少了内核态和用户态之间的切换。也减少了线程的调度问题。

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized刚开始是一个轻量级锁,它会检测发生冲突的情况,如果冲突比较严重,就会变成重量级锁。

1.3自旋锁 挂起等待锁

自旋锁(Spin Lock)
当程序中出现锁竞争时,锁对象要不断的检测锁是否归还,一旦锁被归还,那么就能第一时间拿到锁。但会消耗更多CPU资源,更多的时候是在判断锁是否归还。

我们写出一段关于自旋锁的伪代码来更深入的理解

  while( 抢锁 == 失败) {}

如果抢锁失败的话,就会一直重复的进行这一步操作,直到抢到锁为止。一次次抢锁之间的间隔时间非常短。

一旦锁被其他线程释放,就能第一时间获取到锁。

自旋锁的优缺点

  • 优点: 一旦锁被释放,能第一时间拿到锁
  • 缺点: 会造成资源的浪费,CPU一昧的在空等。

挂起等待锁
当锁竞争时,锁对象会等待一时间,不着急拿到锁,过一段时间再进行抢锁,消耗的CPU资源比较少。

挂起等待锁的优缺点

  • 优点: 减少了资源的消耗
  • 缺点: 不知道什么时候能拿到锁。

自旋锁和挂起等待锁的区别

  1. 自旋锁消耗的资源要比挂起等待锁多,但自旋锁的效率高于挂起等待锁
  2. 挂起等待锁会放弃CPU资源,自选锁不会放弃,会一直到锁释放为止。
  3. 自旋锁相较于挂起等待锁能更及时的获取到刚释放的锁

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized既是自旋锁,也是挂起等待锁。
synchronized锁的轻量级锁是基于自旋锁实现的,基于CAS机制
重量级锁部分基于挂起等待锁实现,通过调用内核api实现。

1.4公平锁 非公平锁

这种锁策略代表着当多个锁竞争时,竞争的规则是什么?
公平锁: 按照先来后到的规则来竞争锁。
非公平锁: 竞争锁时每个对象的机会时均等的。

这种规则是不是不符合我们生活所理解的所认为的公平
在这里插入图片描述
生活就是这样,制定规则的人说什么是公平,那什么就是公平。

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized是非公平锁,也就是机会均等的竞争锁。

1.5可重入锁 不可重入锁

这种锁策略是用来规定 是否允许同一个线程获取同意一把锁
例如递归操作中有锁操作,那么递归过程中这个锁会阻塞自己吗?
如果不会,那就是可重入锁

可重⼊锁的内部, 包含了 线程持有者计数器两个信息.

  • 如果某个线程加锁的时候, 发现锁已经被⼈占用, 但是恰好占⽤的正是自己, 那么仍然可以继续获取到锁, 并让计数器自增.
  • 解锁的时候计数器递减为 0 的时候, 才真正释放锁. (才能被别的线程获取到)

管理是有成本的,可重入锁看起来很理想,但需要考虑是否有必要引入该成本。

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized是可重入锁
mutex锁是不可重入锁

1.6读写锁

多线程之间,数据的读取不会产生线程安全问题,但数据的写入方相互之间以及和读者之间都需要进行互斥。如果两种场景之间都用同一个锁,就会产生极大的性能消耗。

一个线程对数据的访问,主要哟两种操作:读操作写操作

  • 两个线程都只读一个数据,此时并没有线程安全问题,直接并发的读即可
  • 两个线程都要写一个数据,引发线程安全问题
  • 一个线程读,一个线程写,也会引发线程安全问题
  • 线程安全问题转移我上一篇文章链接: 线程安全问题

读写锁

ReentrantReadWriteLock.ReadLock  //读锁
ReentrantReadWriteLock.WriteLock  //写锁

读锁和写锁都提供了lock/unlock方法进行加锁解锁

  • 读加锁和读加锁之间,不互斥
  • 写加锁和写加锁之间,互斥
  • 读加锁和写加锁之间,互斥

读写锁主要适用于“频繁读,不频繁写”的场景中

那么对于我们熟知的synchronized锁来说,它是什么锁呢?
synchronized不是读写锁

✍二、CAS机制

2.1概念

CAS:全程Compare and swap,字面意思是“比较并交换”
CAS操作就是将赋值这一操作进行原子化了。

CAS涉及的操作

假设内存中的原数据V,旧的预期值A,新的预期值B

  1. 比较A与V是否相等 (比较)

  2. 如果比较相等,将B写入V (交换)

  3. 返回操作是否成功

     CAS可以视为是一种乐观锁(可以理解成CAS是乐观锁的一种实现方式)
     
     当多个线程对某个资源进行CAS操作,只能有一个线程能操作成功。
     但是并不会阻塞其他线程,其他线程只会收到操作失败的信号。
    

2.2如何实现?

CAS是如何实现的?
针对不同的操作系统,JVM用到了不同的CAS实现原理,简单来讲:

  • Java的CAS利用的是unsafe这个类提供的CAS操作;
  • unsafe的CAS依赖的是jvm针对不同的操作系统实现的Atomic::cmpxchg;
  • Atomic::cmpxchg的实现使用了汇编的CAS操作,并使用cpu硬件提供的lock机制保证其原子性。

2.3有何应用?

CAS有哪些应用?

①实现原子类

        AtomicInteger atomicInteger = new AtomicInteger(0);
        //相当于 i++;
        atomicInteger.getAndIncrement();

假设两个线程同时调用gerAndIncrement

1.两个线程都读取value的值到oldValue中,(oldValue是一个局部变量,在栈上,每个线程有自己的栈)
在这里插入图片描述

2.线程1先执行CAS操作,由于oldValue和value的值相同,直接及逆行value赋值

注意 
· CAS是直接读写内存的,而不是操作寄存器
· CAS的读内存,比较,写内存操作是一条硬件指令,是原子的

在这里插入图片描述
3.线程2执行CAS,执行第一次时,发现oldValue和value的值不相等,不能进行赋值。因此需要进入循环。
在循环里重新读取value的值赋给oldValue
在这里插入图片描述
4.线程2接下第二次执行CAS(此时因为第一次没有成功,所以还在while循环中),此时oldValue和value相同,于是直接执行赋值操作。
在这里插入图片描述
5.线程1和线程2返回各自的oldValue的值即可。

形如上述代码就可用实现一个原子类,不需要使用重量级锁,就可以高效的完成自增操作。

②实现自旋锁

自旋锁伪代码

class SpinLock{
    private Thread owner = null;
    private void lock(){
        //通过CAS看当前锁是否被某个线程私有
        //如果这个锁已经被别的线程私有,那么就自旋等待
        //如果这个锁没有被其他线程私有,那么就把owner设为当前尝试加锁的线程。
        while (!CAS(this.owner,null,Thread.currentThread())){
            
        }
    }
    public void unlock(){
        this.owner = null;
    }
}

2.4锁的ABA问题

ABA问题:
假设存在两个线程t1和t2,有一个共享变量num,初始值为A
接下来,线程t1想使用CAS把num值改成Z,那么就需要

  • 先读取num的值,记录到oldNum变量中
  • 是同CAS判定当前num的值是否为A,如果为A,就修改为Z。
线程t1的CAS期望时num不变就修改为,但num的值已经被t2给改了,
只不过又改成A了,这个时候t1究竟是否要更新num的值为Z呢?

到这一步,t1线程无法区分当前这个变量始终是A,还是经历了一个变化过程。
在这里插入图片描述

引起的BUG
在大部分情况下,是没有问题的,但总是存在一些特殊情况

小帅和小美生育有一子,孩子两岁了,需要去打疫苗,医院给小帅和小美发去了短信,要求他们这周末孩子去医院打疫苗,并在社区医院的表格报备;
我们期望 一个人带孩子去打疫苗并在社区医院表格中报备了,另一个人发现已经报备了,不需要再打疫苗了。
如果使用CAS的方式来完成这个打疫苗过程就可能出现问题。

正常的过程

  1. 小帅看见社区医院的表格没有报备,小帅带孩子去打疫苗。小美看见社区医院的表格没有报备,小美带孩子去打疫苗
  2. 小帅带孩子打了疫苗,孩子被小帅带走了,小美在家等待。
  3. 小帅带孩子回来了,并在社区医院表格中报备,小美通过查看表格知道了孩子已经打了疫苗,就不带孩子去医院了。

异常BUG

  1. 小帅看见社区医院的表格没有报备,小帅带孩子去打疫苗。小美看见社区医院的表格没有报备,小美带孩子去打疫苗
  2. 小帅带孩子打了疫苗,孩子被小帅带走了,小美在家等待。
  3. 小帅带孩子打完了疫苗,公司有事,把孩子送回家马上回公司了,并没有在社区医院表格中报备。此时小美拿到孩子,看见表格中没有报备,以为小帅带孩子出去玩了。小美就带孩子去了医院
  4. 小美到医院给医生说,孩子要打疫苗,孩子又被打了一针疫苗
    在这里插入图片描述
这时孩子就被打了两次疫苗!!!都是ABA问题搞的鬼。
孩子过两天就死了!!!孩子才两岁,也不会说话!!!
吃了没文化的亏!!!
所以奉劝大家一定要好好学习哈哈

既然问题这么严重,就给出解决方案来解决这个问题

解决方案
给要修改的值,引入版本号,在CAS比较数据当前值和旧值的同时,也要比较版本号是否符合预期。

  • CAS操作在读取旧值的同时,也要读取版本号。
  • 真正修改的时候,
    – 如果当前版本号和读到的版本号相同,则修改数据,并把版本号+1.
    –如果当前版本号高于读到的版本号,就操作失败(认为数据已经被修改过了)。

对比理解上面打疫苗的例子

版本号就相当于医院的疫苗接种单
打了疫苗,医院就会在疫苗接种单上盖章。
我们搭配一个版本号,初始为1
  1. 小帅看见社区医院的表格没有报备,版本号为1,小帅带孩子去打疫苗。小美看见社区医院的表格没有报备,版本号为1,小美带孩子去打疫苗
  2. 小帅带孩子打了疫苗,孩子被小帅带走了,打了疫苗,版本号为2,小美在家等待。
  3. 小帅带孩子打完了疫苗,公司有事,把孩子送回家马上回公司了,并没有在社区医院表格中报备,但版本号为2。
  4. 此时小美拿到孩子,看见表格中没有报备,以为小帅带孩子出去玩了。小美就准备带孩子去医院,但是发现此时版本号为2,和之前读到的版本号1不相同,版本小于当前版本,认为操作失败。

✍三、锁优化策略

JVM将synchronized锁分为 无锁、偏向锁、轻量级锁、重量级锁。
会根据情况,进行一次升级。
在这里插入图片描述

3.1偏向锁

第⼀个尝试加锁的线程, 优先进⼊偏向锁状态.
偏向锁不是真的 "加锁", 只是给对象头中做⼀个 "偏向锁的标记", 记录这个锁属于哪个线程.
如果后续没有其他线程来竞争该锁, 那么就不⽤进⾏其他同步操作了(避免了加锁解锁的开销)
如果后续有其他线程来竞争该锁(刚才已经在锁对象中记录了当前锁属于哪个线程了, 很容易识别当前
申请锁的线程是不是之前记录的线程), 那就取消原来的偏向锁状态, 进⼊⼀般的轻量级锁状态.
偏向锁本质上相当于 "延迟加锁" . 能不加锁就不加锁, 尽量来避免不必要的加锁开销.
但是该做的标记还是得做的, 否则⽆法区分何时需要真正加锁.

3.2轻量级锁

随着其他线程进⼊竞争, 偏向锁状态被消除, 进⼊轻量级锁状态(⾃适应的⾃旋锁).
此处的轻量级锁就是通过 CAS 来实现.

  • 通过 CAS 检查并更新⼀块内存 (⽐如 null => 该线程引⽤)
  • 如果更新成功, 则认为加锁成功
  • 如果更新失败, 则认为锁被占⽤, 继续⾃旋式的等待(并不放弃 CPU).

⾃旋操作是⼀直让 CPU 空转, ⽐较浪费 CPU 资源.
因此此处的⾃旋不会⼀直持续进⾏, ⽽是达到⼀定的时间/重试次数, 就不再⾃旋了.
也就是所谓的 “⾃适应”

3.3自旋锁

如果竞争进⼀步激烈, ⾃旋不能快速获取到锁状态, 就会膨胀为重量级锁
此处的重量级锁就是指⽤到内核提供的 mutex .

  • 执⾏加锁操作, 先进⼊内核态.
  • 在内核态判定当前锁是否已经被占⽤
  • 如果该锁没有占⽤, 则加锁成功, 并切换回⽤⼾态.
  • 如果该锁被占⽤, 则加锁失败. 此时线程进⼊锁的等待队列, 挂起. 等待被操作系统唤醒.
  • 经历了⼀系列的沧海桑⽥, 这个锁被其他线程释放了, 操作系统也想起了这个挂起的线程, 于是唤醒
    这个线程, 尝试重新获取锁.

3.4其他锁优化

①锁消除

编译器+JVM 判断锁是否可消除. 如果可以, 就直接消除.

②锁粗化

⼀段逻辑中如果出现多次加锁解锁, 编译器 + JVM 会⾃动进⾏锁的粗化

锁的颗粒: 锁的粒度: 粗和细
实际开发过程中, 使⽤细粒度锁, 是期望释放锁的时候其他线程能使⽤锁.
但是实际上可能并没有其他线程来抢占这个锁. 这种情况 JVM 就会⾃动把锁粗化, 避免频繁申请释放
锁.

举个例子来理解锁粗化

小明妈妈让小明去超市买东西

第一种方式

  • 打电话,让小明买酱油,挂电话
  • 打电话,让小明买白醋,挂电话
  • 打电话,让小明买抹布,挂电话

第二种方式

  • 打电话,让小明买酱油,白醋,抹布,挂电话

显然第二种方式更高效


以上就是本文所有内容,如果对你有帮助的话,点赞收藏支持一下吧!💞💞💞

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

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

相关文章

收集统计信息报错ora-00600[16515]问题处理

1、基础环境 操作系统Oracle Solaris 11.3 数据版本Oracle 12.2 2、故障理像 对一个20T的大库收集一下全库的统计信息 原因是现在都2024年了,这个库的统计信息基本都是2021年, 没具体查找啥原因导致的系统自定义的收集任务失败,于是决定手…

2024年内外贸一体化融合发展(长沙)交易会

2024年内外贸一体化融合发展(长沙)交易会 一、总体思路 充分发挥湖南作为全国内外贸一体化试点地区作用,坚持“政府主导、市场驱动、企业为主”的原则,以“助力双循环,拓展新市场,促进新消费”为主题&…

腾讯云服务器价格明细表2024年最新(CPU内存/带宽/磁盘)

腾讯云服务器价格明细表2024年最新(CPU内存/带宽/磁盘)腾讯云服务器租用优惠价格表:轻量应用服务器2核2G3M价格61元一年,2核2G4M价格99元一年、135元15个月、540元三年,2核4G5M带宽165元一年、252元15个月、756元3年&a…

VBA运行后,为什么excel的三个工作表结果一样?

运行完了excel的三个工作表的结果一样,问题在哪呢? 代码如下: Sub 计算成绩() 计算成绩 Macro i为工作表行号 Dim i, m, total As Integer Dim w1 As Worksheet For m 1 To Worksheets.count Set w1 Worksheets(m) i 2 total 0 …

【MySQL 数据宝典】【磁盘结构】- 002 数据字典

一、数据字典 ( Data Dictionary ) 1.1 背景介绍 我们平时使用 INSERT 语句向表中插入的那些记录称之为用户数据,MySQL只是作为一个软件来为我们来保管这 些数据,提供方便的增删改查接口而已。但是每当我们向一个表中插入一条记录的时候,MyS…

ZISUOJ 数据结构--队列及其应用

说明: 基本都是bfs的常见模板题型,思路都很直接,不过后面有两道题很搞心态,它们给的坐标x、y是反的,导致刚开始一直错。题目还是要看仔细,不能先入为主。 题目列表: 问题 A: 围圈报数(完善程序…

Python实现对波士顿房价的分析与预测

文章目录 问题分析所需环境代码实现1. 相关性分析及可视化2. 房价分析及可视化3. 构建房价预测模型问题分析 波士顿房价数据集包含美国人口普查局收集的美国马萨诸塞州波士顿住房价格的有关信息, 数据集很小,只有506个案例。 数据集都有以下14个属性,具体含义如下 现在需要…

工业控制(ICS)---组态软件分析

组态软件 什么是组态软件? 组态软件就是一些数据采集与过程控制的专用软件,它们是在自动控制系统监控层一级的软件平台和开发环境,使用灵活的组态方式,为用户提供快速构建工业自动控制系统监控功能的通用层次的软件工具。 组态软…

轮转数组(Leedcode)的题目

题目:给定一个整数数组 nums,将数组中的元素向右轮转 k 个位置,其中 k 是非负数。 示例 1: 输入: nums [1,2,3,4,5,6,7], k 3 输出: [5,6,7,1,2,3,4] 解释: 向右轮转 1 步: [7,1,2,3,4,5,6] 向右轮转 2 步: [6,7,1,2,3,4,5] 向右轮转 3 步…

恶心透了的小日子,害人终害己,国货呼吁关注抵制日本核废水排放

​|日本排放核废水 日本政府决定将福岛第一核电站的核污染水经过处理后排放入海,这一决定引发了多方面的担忧和反对,特别是在周边国家,包括中国和韩国。关于日本排放核污染水这一新闻事件,我们必须首先认识到,核能利用…

二百三十三、Flume——Flume采集JSON文件到Kafka,再用Flume采集Kafka数据到HDFS中

一、目的 由于使用了新的Kafka协议,因为根据新的协议推送模拟数据到Kafka中,再Flume采集Kafka数据到HDFS中 二、技术选型 (一)Kettle工具 准备使用Kettle的JSON input控件和Kafka producer控件,但是搞了1天没搞定&…

《自动机理论、语言和计算导论》阅读笔记:p261-p314

《自动机理论、语言和计算导论》学习第 10 天,p261-p314总结,总计 48 页。 一、技术总结 1.generating & reachable 2.Chomsky Normal Form(CNF) 乔姆斯基范式。 3.pumping lemma 泵作用引理。引理:引理是数学中为了取得某个更好的…

基于docker搭建瀚高数据库HighGo6.0.1【图文】

基于docker搭建瀚高数据库HighGo6.0.1 拉取镜像启动验证进入容器 登录数据库查看数据库加密方式修改加密方式为sm3进入数据库修改密码重启容器 数据库验证数据库密码到期参考 docker部署 https://blog.csdn.net/weixin_44385419/article/details/127738868 拉取镜像 docker p…

【ARM Trace32(劳特巴赫) 使用介绍 12.1 -- Trace32 读写 64位地址】

请阅读【Trace32 ARM 专栏导读】 文章目录 Trace32 读写 64位地址读 64 位地址写64位地址Trace32 读写 64位地址 在使用TRACE32进行调试时,有时需要读取或操作64位的地址,特别是在处理64位的处理器或操作系统时。以下是如何在TRACE32中读取64位地址的一般方法。 读 64 位地…

数据可视化(八):Pandas时间序列——动态绘图,重采样,自相关图,偏相关图等高级操作

Tips:"分享是快乐的源泉💧,在我的博客里,不仅有知识的海洋🌊,还有满满的正能量加持💪,快来和我一起分享这份快乐吧😊! 喜欢我的博客的话,记得…

IPD集成产品开发(二)

时间:2024年04月21日 作者:小蒋聊技术 邮箱:wei_wei10163.com 微信:wei_wei10 音频地址:IPD集成产品开发(二)https://www.ximalaya.com/sound/724309598 大家好,欢迎来到小蒋聊技…

前端三剑客 HTML+CSS+JavaScript ③ HTML标准结构

生活没有任何意义&#xff0c;这就是活着的理由&#xff0c;而且是唯一的理由 —— 24.4.22 一、HTML注释 1.特点 注释的内容会被浏览器所忽略&#xff0c;不会呈现到页面中&#xff0c;但源代码中依然可见 2.作用 对代码进行解释和说明 3.写法 <!-- xxxxx --> <html&…

【Web】2022DASCTF X SU 三月春季挑战赛 题解(全)

目录 ezpop calc upgdstore ezpop 瞪眼看链子 fin#__destruct -> what#__toString -> fin.run() -> crow#__invoke -> fin#__call -> mix.get_flag() exp <?php class crow {public $v1;public $v2;}class fin {public $f1; }class what {public $a; }…

grafana安装篇(1)

目录 grafana概念&#xff1a; 它具有以下主要特点&#xff1a; Grafana 常用于以下场景&#xff1a; 环境介绍&#xff1a; 前置环境&#xff1a; (1)保证可以连接外网 (2)防火墙和selinux已关闭 1.下载安装grafana10.0.1-1rpm包 2.启动grafana 3.浏览器访问 3.设置…

android学习笔记(五)-MVP模式

1、MVP模式demo的实现&#xff0c;效果下&#xff1a; 2、创建一个Fruit类&#xff1a; package com.example.listview; //Fruit类就是Model&#xff0c;表示应用程序中的数据对象。 public class Fruit {private int imageId;private String name;private String price;publi…