Java 多线程之 CAS(Compare and Set),实现无锁优化,自旋锁/乐观锁
文章目录
- 一、概述
- 二、JDK 的 Unsafe 类
- 三、ABA 问题
一、概述
-
CAS(Compare and Swap)是一种并发编程中的原子操作(synchronized 也使用了 CAS),用于实现多线程环境下的同步和数据共享。CAS提供了一种高效的并发控制机制,可以避免传统锁机制的开销和问题。
-
CAS操作包括三个操作数:内存位置(通常是共享的变量)、旧的预期值和新的值。
- CAS操作会先比较内存位置上的值与旧的预期值是否相等,如果相等,则将新的值写入该内存位置;如果不相等,则说明其他线程已经修改了该内存位置的值,CAS操作失败,不会进行写入操作。
-
CAS的优势和应用场景如下:
-
非阻塞:CAS是一种非阻塞的原子操作,不会引起线程的阻塞和切换,提高了并发性能。
-
原子性:CAS操作是原子的,要么成功执行写入操作,要么失败不写入,不存在中间状态。
-
无锁:CAS不需要使用传统锁机制(如互斥锁)来保护共享资源,避免了锁带来的线程阻塞和上下文切换开销。
-
并发控制:CAS可以用于并发控制,例如实现线程安全的计数器、自旋锁、无锁队列等数据结构。
-
无死锁:由于CAS不使用锁,因此不存在死锁的问题。
-
-
尽管CAS具有上述优势,但也存在一些限制和注意事项:
-
ABA问题:CAS只能检测到预期值是否相等,无法感知到变量值的修改过程中是否发生了其他的并发修改,可能会引发ABA问题。
-
自旋次数:在CAS操作失败时,为了尝试成功,可能会进行自旋操作,如果自旋次数过多,会消耗过多的CPU资源。
-
适用性:CAS适用于共享变量的简单操作,对于复杂的操作可能不适合使用CAS。
-
-
java.util.concurrent.atomic.Atomic* 开头的类都用 CAS 实现无锁优化。
二、JDK 的 Unsafe 类
-
Unsafe 提供了一系列低级的、直接操作内存和线程的方法,属于 Java 的核心库之一。由于 Unsafe 提供了直接操作内存和线程的能力,因此它具有很大的潜在危险性,一般建议开发者避免直接使用它,尽量使用更高级别的抽象和标准库提供的功能。
-
下面是 Unsafe 类的一些常见用途:
-
CAS 操作:Unsafe 提供了一系列的 CAS(Compare and Swap)操作方法,用于实现原子性操作,如原子更新字段、原子更新数组等。
// unsafe 类使用 CAS 的方法的代码片段 public final class Unsafe {public final native boolean compareAndSwapObject(Object var1, long var2, Object var4, Object var5);public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5);public final native boolean compareAndSwapLong(Object var1, long var2, long var4, long var6); } -
直接内存操作:Unsafe 提供了分配和释放直接内存的方法,可以绕过 Java 堆内存的管理,直接操作底层的内存区域。有allocateMemory、freeMemory、putXX、pageSize类似于C语言中malloc,free等方法。
-
线程操作:Unsafe 提供了线程的挂起、恢复、创建和销毁等方法,可以直接操作线程。
-
数组操作:Unsafe 可以直接操作数组的内存,并提供了一些方法来获取数组元素的偏移地址、更新数组元素等。
-
内存屏障操作:Unsafe 提供了内存屏障(Memory Barrier)的操作方法,用于控制内存的可见性和指令重排序。
-
直接生类实例allocateInstance,直接操作类或实例变量objectFieldOffset、getInt、getObject,CAS相关操作weakCompareAndSetObject Int Long。
-
三、ABA 问题
ABA 问题 对值类型没有问题,有问题的是对象类型。
-
ABA 问题描述
- ABA 问题是指在并发环境下,当一个变量的值从 A 变为 B,然后再变回 A,导致某些操作无法正确检测到中间的变化。
- ABA 问题的典型场景是使用 CAS(Compare and Swap)操作时发生。CAS 操作涉及比较当前内存位置的值与期望值,如果相等,则进行交换。然而,在一个线程执行 CAS 操作的过程中,其他线程可能修改了内存位置的值,然后又恢复为原始值,这样 CAS 操作将会成功,但实际上内存位置的值已经发生了变化。
-
下面一个简化的示例来说明 ABA 问题:
- 假设有两个线程 T1 和 T2,共享一个变量 value 的初始值为 A。执行过程如下:
- (1)T1 读取 value 的当前值 A。
- (2)在 T1 进行 CAS 操作之前,T2 修改 value 的值为 B。
- (3)T2 又将 value 的值修改回 A。
- (4)T1 执行 CAS 操作,发现 value 的当前值仍然是 A,CAS 操作成功。
- 在这个例子中,T1 使用 CAS 操作时,期望值是 A,实际上经历了从 A 到 B 再到 A 的变化。尽管 CAS 操作成功,但是它无法感知到中间的 B 的变化,从而可能导致意外的结果。
- 假设有两个线程 T1 和 T2,共享一个变量 value 的初始值为 A。执行过程如下:
-
ABA 问题可能会对某些场景产生影响,例如使用 CAS 操作来实现并发数据结构,或者在实现一些复杂的算法时。为了解决 ABA 问题,需要额外的手段来检测变化,例如使用版本号、标记位或引入额外的同步机制。
-
在 Java 中,AtomicStampedReference 类是专门设计用于解决 ABA 问题的。它通过引入版本号来区分不同的状态,从而检测到变化。
相关文章:
Java 多线程之 CAS(Compare and Set),实现无锁优化,自旋锁/乐观锁
文章目录 一、概述二、JDK 的 Unsafe 类三、ABA 问题 一、概述 CAS(Compare and Swap)是一种并发编程中的原子操作(synchronized 也使用了 CAS),用于实现多线程环境下的同步和数据共享。CAS提供了一种高效的并发控制机…...
python之pyqt专栏1-环境搭建
#python pyqt# python:3.11.6 pycharm:PyCharm Community Edition 2023.2.5 pyqt6 python安装 官网下载:Python Releases for Windows | Python.org pycharm社区版安装 官网地址:Download PyCharm: Python IDE for Professional…...
Spring Cloud LoadBalancer 简单介绍与实战
前言 本文为SpringCloud的学习笔记,如有错误,希望各位高手能指出,主要介绍SpringCloudLoadBalancer的基本概念和实战 文章目录 前言什么是LoadBalancer负载均衡分类服务端负载均衡客户端负载均衡服务端负载均衡和客户端负载均衡的优缺点 常见…...
私域流量解决方案分享
...
Scala---WordCount
一、创建Maven项目导入pom.xml文件 安装Maven仓库管理工具,版本要求是3.2版本以上。新建Maven项目,配置pom.xml。导入必要的包。 二、Spark-Scala版本的WordCount 1.val conf new SparkConf() 2.conf.setMaster("local") 3.conf.setAppNam…...
GTC2023全球流量大会蓄势待发,菊风在7B57展位等你!
第六届 GTC 全球流量大会(以下简称 GTC2023)将于12月5日- 6日,在深圳福田会展中心7&8号馆举办。 据悉,本届大会将是历届以来规模最大、参与人数最多、跨境出海资源最丰富的一次行业盛会。7、8 号馆共 15000 平方米&am…...
喜讯!云起无垠成为国家信息安全漏洞库(CNNVD)技术支撑单位
近日,云起无垠凭借其在漏洞挖掘、漏洞检测以及漏洞修复等领域的卓越表现,荣获“国家信息安全漏洞库(CNNVD)技术支撑单位等级证书(三级)”,正式成为CNNVD技术支撑单位。 中国国家信息安全漏洞库&…...
cc linux用root用户执行chmod 777 -R ./提示 Operation not permitted怎么办?
如果你作为 root 用户执行 chmod 777 -R ./ 命令时收到 “Operation not permitted” 错误,可能有几个原因: 不可更改 (Immutable) 文件属性: 文件可能被设置为不可更改。即使是 root 用户也不能修改这些文件的权限。使用 lsattr 命令查看文件…...
scrapy框架流程
1、Scrapy从Spider子类中提取start_url,然后构造为request请求对象 2、将request请求对象传递给爬虫中间件 3、将request请求对象传递给Scrapy引擎(核心代码) 4、将request请求对象传递给调度器(它负责对多个request安排,好比交…...
802.11 帧的Reason Code 位和Status Code 位
Reason Code 位 当对方不适合加入网络时,工作站会送出 Disassociation(解除连接)或 Deauthentication(解除身份认证)帧作为应答。这些帧当中包含一个长度 16bit 的 Reason Code(原因代码)位&am…...
骨传导能保护听力吗?为什么说骨传导耳机可以保护听力?
由于骨传导耳机的特殊传声方式,是可以保护听力的。 首先了解下骨传导耳机的传声方式是什么: 骨传导耳机是通过骨骼震动传导技术,将声音传至颅骨,然后通过颅骨传导到内耳,直接刺激听觉神经,使人感知到声音…...
【iOS】实现评论区展开效果
文章目录 前言实现行高自适应实现评论展开效果解决cell中的buttom的复用问题 前言 在知乎日报的评论区中,用到了Masonry行高自适应来实现评论的展开,这里设计许多控件的约束问题,当时困扰了笔者许久,特此撰写博客记录 实现行高自…...
POE交换机——电源解决方案-升压控制器\降压控制器\中高压降压转换器
PoE是一种有线以太网供电技术,使用于数据传输的网线同时具备直流供电的能力,PoE供电具有可靠、连接简捷、标准统一的优势。越来越多的工业物联网设备开始采用PoE供电, 如IP电话、网络视频监控以及无线以太网设备等。 PoE交换机是一种用于提供…...
[C/C++]数据结构 循环队列
前言: 队列是一种具有先进先出特性的结构,但是当数据出队列以后,前面的空间就无法再次利用了,循环队列就可以解决这个问题 一:概念及结构: 1.循环队列概念 循环队列是一种线性数据结构,其操作表现基于 FIFO(先进先出)原则并且队尾被连接在队…...
Cache学习(2):Cache结构 命中与缺失 多级Cache结构 直接映射缓存
1 Cache名词解释 命中(hit): CPU要访问的数据在Cache中有缓存缺失(miss): CPU要访问的数据在Cache中没有缓存Cache Size:Cache的大小,代表Cache可以缓存最大数据的大小Cache Line&a…...
vue前端前端页面权限验证方式
在Vue应用中使用Vuex(Vue的状态管理库)来存储用户组(user group)和角色(roles)信息是一种合理的做法,特别是在涉及到权限管理和用户身份的情况下。Vuex提供了一个集中式的状态管理方案ÿ…...
jenkins springCloud项目优雅下线
文章目录 场景解决下线请求效果如图贴一个可用的部署脚本 场景 在 Spring Cloud 项目的微服务实例关闭时,需要首先从注册中心设置为下线,避免该服务的消费者继续请求该服务实例,导致请求失败如果我们在服务实例从注册中心取消注册后ÿ…...
indexOf
可以通過String的indexOf判斷是否包括某個字符。 SpringBootTest Slf4j class BaseApplicationTests {Testvoid contextLoads() {log.info("01".indexOf(".")"");log.info("0.1".indexOf(".")"");log.info("…...
STM32分区跳转问题
项目场景: 在OTA中,FLASH通常被划分为以下几种类型 bootloaderiapappbootloaderappapp保存区bootloaderapp1app2 不同的分区方式有不同的有点,但是共同点都是需要执行分区跳转 问题1描述 但在分区跳转过程中遇到过使用不同的编译器不能跳转…...
亿级流量架构服务降级
什么是服务降级 如果看过我前面对服务限流的分析,理解服务降级就很容易了,对于一个景区,平时随便进出,但是一到春节或者十一国庆这种情况客流量激增,那么景区会限制同时进去的人数,这叫限流,那么什么是服务降级呢? 简单来说就是,将一些不太重要的景区项目砍掉,平时就那么三五…...
Vue记事本应用实现教程
文章目录 1. 项目介绍2. 开发环境准备3. 设计应用界面4. 创建Vue实例和数据模型5. 实现记事本功能5.1 添加新记事项5.2 删除记事项5.3 清空所有记事 6. 添加样式7. 功能扩展:显示创建时间8. 功能扩展:记事项搜索9. 完整代码10. Vue知识点解析10.1 数据绑…...
.Net框架,除了EF还有很多很多......
文章目录 1. 引言2. Dapper2.1 概述与设计原理2.2 核心功能与代码示例基本查询多映射查询存储过程调用 2.3 性能优化原理2.4 适用场景 3. NHibernate3.1 概述与架构设计3.2 映射配置示例Fluent映射XML映射 3.3 查询示例HQL查询Criteria APILINQ提供程序 3.4 高级特性3.5 适用场…...
家政维修平台实战20:权限设计
目录 1 获取工人信息2 搭建工人入口3 权限判断总结 目前我们已经搭建好了基础的用户体系,主要是分成几个表,用户表我们是记录用户的基础信息,包括手机、昵称、头像。而工人和员工各有各的表。那么就有一个问题,不同的角色…...
【ROS】Nav2源码之nav2_behavior_tree-行为树节点列表
1、行为树节点分类 在 Nav2(Navigation2)的行为树框架中,行为树节点插件按照功能分为 Action(动作节点)、Condition(条件节点)、Control(控制节点) 和 Decorator(装饰节点) 四类。 1.1 动作节点 Action 执行具体的机器人操作或任务,直接与硬件、传感器或外部系统…...
汇编常见指令
汇编常见指令 一、数据传送指令 指令功能示例说明MOV数据传送MOV EAX, 10将立即数 10 送入 EAXMOV [EBX], EAX将 EAX 值存入 EBX 指向的内存LEA加载有效地址LEA EAX, [EBX4]将 EBX4 的地址存入 EAX(不访问内存)XCHG交换数据XCHG EAX, EBX交换 EAX 和 EB…...
成都鼎讯硬核科技!雷达目标与干扰模拟器,以卓越性能制胜电磁频谱战
在现代战争中,电磁频谱已成为继陆、海、空、天之后的 “第五维战场”,雷达作为电磁频谱领域的关键装备,其干扰与抗干扰能力的较量,直接影响着战争的胜负走向。由成都鼎讯科技匠心打造的雷达目标与干扰模拟器,凭借数字射…...
全面解析各类VPN技术:GRE、IPsec、L2TP、SSL与MPLS VPN对比
目录 引言 VPN技术概述 GRE VPN 3.1 GRE封装结构 3.2 GRE的应用场景 GRE over IPsec 4.1 GRE over IPsec封装结构 4.2 为什么使用GRE over IPsec? IPsec VPN 5.1 IPsec传输模式(Transport Mode) 5.2 IPsec隧道模式(Tunne…...
python执行测试用例,allure报乱码且未成功生成报告
allure执行测试用例时显示乱码:‘allure’ �����ڲ����ⲿ���Ҳ���ǿ�&am…...
[免费]微信小程序问卷调查系统(SpringBoot后端+Vue管理端)【论文+源码+SQL脚本】
大家好,我是java1234_小锋老师,看到一个不错的微信小程序问卷调查系统(SpringBoot后端Vue管理端)【论文源码SQL脚本】,分享下哈。 项目视频演示 【免费】微信小程序问卷调查系统(SpringBoot后端Vue管理端) Java毕业设计_哔哩哔哩_bilibili 项…...
Sklearn 机器学习 缺失值处理 获取填充失值的统计值
💖亲爱的技术爱好者们,热烈欢迎来到 Kant2048 的博客!我是 Thomas Kant,很开心能在CSDN上与你们相遇~💖 本博客的精华专栏: 【自动化测试】 【测试经验】 【人工智能】 【Python】 使用 Scikit-learn 处理缺失值并提取填充统计信息的完整指南 在机器学习项目中,数据清…...
