当前位置: 首页 > news >正文

Java 多线程之 CAS(Compare and Set),实现无锁优化,自旋锁/乐观锁

文章目录

    • 一、概述
    • 二、JDK 的 Unsafe 类
    • 三、ABA 问题

一、概述

  • CAS(Compare and Swap)是一种并发编程中的原子操作(synchronized 也使用了 CAS),用于实现多线程环境下的同步和数据共享。CAS提供了一种高效的并发控制机制,可以避免传统锁机制的开销和问题。

  • CAS操作包括三个操作数:内存位置(通常是共享的变量)、旧的预期值和新的值。

    • CAS操作会先比较内存位置上的值与旧的预期值是否相等,如果相等,则将新的值写入该内存位置;如果不相等,则说明其他线程已经修改了该内存位置的值,CAS操作失败,不会进行写入操作。
  • CAS的优势和应用场景如下:

    1. 非阻塞:CAS是一种非阻塞的原子操作,不会引起线程的阻塞和切换,提高了并发性能。

    2. 原子性:CAS操作是原子的,要么成功执行写入操作,要么失败不写入,不存在中间状态。

    3. 无锁:CAS不需要使用传统锁机制(如互斥锁)来保护共享资源,避免了锁带来的线程阻塞和上下文切换开销。

    4. 并发控制:CAS可以用于并发控制,例如实现线程安全的计数器、自旋锁、无锁队列等数据结构。

    5. 无死锁:由于CAS不使用锁,因此不存在死锁的问题。

  • 尽管CAS具有上述优势,但也存在一些限制和注意事项:

    1. ABA问题:CAS只能检测到预期值是否相等,无法感知到变量值的修改过程中是否发生了其他的并发修改,可能会引发ABA问题。

    2. 自旋次数:在CAS操作失败时,为了尝试成功,可能会进行自旋操作,如果自旋次数过多,会消耗过多的CPU资源。

    3. 适用性: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 的变化,从而可能导致意外的结果。
  • 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提供了一个集中式的状态管理方案&#xff…...

jenkins springCloud项目优雅下线

文章目录 场景解决下线请求效果如图贴一个可用的部署脚本 场景 在 Spring Cloud 项目的微服务实例关闭时,需要首先从注册中心设置为下线,避免该服务的消费者继续请求该服务实例,导致请求失败如果我们在服务实例从注册中心取消注册后&#xff…...

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描述 但在分区跳转过程中遇到过使用不同的编译器不能跳转…...

亿级流量架构服务降级

什么是服务降级 如果看过我前面对服务限流的分析,理解服务降级就很容易了,对于一个景区,平时随便进出,但是一到春节或者十一国庆这种情况客流量激增,那么景区会限制同时进去的人数,这叫限流,那么什么是服务降级呢? 简单来说就是,将一些不太重要的景区项目砍掉,平时就那么三五…...

日语AI面试高效通关秘籍:专业解读与青柚面试智能助攻

在如今就业市场竞争日益激烈的背景下,越来越多的求职者将目光投向了日本及中日双语岗位。但是,一场日语面试往往让许多人感到步履维艰。你是否也曾因为面试官抛出的“刁钻问题”而心生畏惧?面对生疏的日语交流环境,即便提前恶补了…...

树莓派超全系列教程文档--(62)使用rpicam-app通过网络流式传输视频

使用rpicam-app通过网络流式传输视频 使用 rpicam-app 通过网络流式传输视频UDPTCPRTSPlibavGStreamerRTPlibcamerasrc GStreamer 元素 文章来源: http://raspberry.dns8844.cn/documentation 原文网址 使用 rpicam-app 通过网络流式传输视频 本节介绍来自 rpica…...

工业安全零事故的智能守护者:一体化AI智能安防平台

前言: 通过AI视觉技术,为船厂提供全面的安全监控解决方案,涵盖交通违规检测、起重机轨道安全、非法入侵检测、盗窃防范、安全规范执行监控等多个方面,能够实现对应负责人反馈机制,并最终实现数据的统计报表。提升船厂…...

安宝特方案丨XRSOP人员作业标准化管理平台:AR智慧点检验收套件

在选煤厂、化工厂、钢铁厂等过程生产型企业,其生产设备的运行效率和非计划停机对工业制造效益有较大影响。 随着企业自动化和智能化建设的推进,需提前预防假检、错检、漏检,推动智慧生产运维系统数据的流动和现场赋能应用。同时,…...

大数据零基础学习day1之环境准备和大数据初步理解

学习大数据会使用到多台Linux服务器。 一、环境准备 1、VMware 基于VMware构建Linux虚拟机 是大数据从业者或者IT从业者的必备技能之一也是成本低廉的方案 所以VMware虚拟机方案是必须要学习的。 (1)设置网关 打开VMware虚拟机,点击编辑…...

电脑插入多块移动硬盘后经常出现卡顿和蓝屏

当电脑在插入多块移动硬盘后频繁出现卡顿和蓝屏问题时,可能涉及硬件资源冲突、驱动兼容性、供电不足或系统设置等多方面原因。以下是逐步排查和解决方案: 1. 检查电源供电问题 问题原因:多块移动硬盘同时运行可能导致USB接口供电不足&#x…...

React19源码系列之 事件插件系统

事件类别 事件类型 定义 文档 Event Event 接口表示在 EventTarget 上出现的事件。 Event - Web API | MDN UIEvent UIEvent 接口表示简单的用户界面事件。 UIEvent - Web API | MDN KeyboardEvent KeyboardEvent 对象描述了用户与键盘的交互。 KeyboardEvent - Web…...

【git】把本地更改提交远程新分支feature_g

创建并切换新分支 git checkout -b feature_g 添加并提交更改 git add . git commit -m “实现图片上传功能” 推送到远程 git push -u origin feature_g...

Unit 1 深度强化学习简介

Deep RL Course ——Unit 1 Introduction 从理论和实践层面深入学习深度强化学习。学会使用知名的深度强化学习库,例如 Stable Baselines3、RL Baselines3 Zoo、Sample Factory 和 CleanRL。在独特的环境中训练智能体,比如 SnowballFight、Huggy the Do…...

汇编常见指令

汇编常见指令 一、数据传送指令 指令功能示例说明MOV数据传送MOV EAX, 10将立即数 10 送入 EAXMOV [EBX], EAX将 EAX 值存入 EBX 指向的内存LEA加载有效地址LEA EAX, [EBX4]将 EBX4 的地址存入 EAX(不访问内存)XCHG交换数据XCHG EAX, EBX交换 EAX 和 EB…...