JUC并发编程之原子类

目录

1. 什么是原子操作

1.1 原子类的作用

1.2 原子类的常见操作

原子类的使用注意事项


并发编程是现代计算机应用中不可或缺的一部分,而在并发编程中,处理共享资源的并发访问是一个重要的问题。为了避免多线程访问共享资源时出现竞态条件(Race Condition)等问题,Java提供了一组原子类(Atomic Classes)来支持线程安全的操作。

1. 什么是原子操作

在并发编程中,原子操作是不可被中断的一个或一系列操作,要么全部执行成功,要么全部不执行,不会出现部分执行的情况。原子操作能够保证在多线程环境下,对共享资源的操作不会相互干扰,从而确保数据的一致性和可靠性。

1.1 原子类的作用

Java提供了一组原子类,位于java.util.concurrent.atomic包中,用于在多线程环境下进行原子操作。这些原子类利用底层的硬件支持或自旋锁等机制来实现线程安全的操作,避免了显式地使用synchronized关键字等锁机制,从而提高了并发性能。

原子类的作用主要有以下几点:

  1. 提供线程安全的操作: 原子类提供了一些常见的操作,如读取、更新、比较交换等,这些操作在执行时不会受到其他线程的干扰,从而确保数据的一致性。

  2. 避免竞态条件: 使用原子类可以有效地避免多线程环境下的竞态条件问题,例如多个线程同时对同一个变量进行操作,可能导致不可预测的结果。

  3. 提高性能: 原子类在实现上利用了一些底层的技术,避免了传统锁机制的开销,因此在某些情况下可以提供更好的性能。

1.2 原子类的常见操作

1. AtomicBoolean

AtomicBoolean类提供了原子的布尔值操作,支持原子的设置和获取操作。

AtomicBoolean atomicBoolean = new AtomicBoolean(true);boolean currentValue = atomicBoolean.get(); // 获取当前值
boolean updatedValue = atomicBoolean.compareAndSet(true, false); // 如果当前值为true,则设置为false

 

2. AtomicInteger 和 AtomicLong

AtomicIntegerAtomicLong分别提供了原子的整数和长整数操作,包括增加、减少、获取等操作。

AtomicInteger atomicInt = new AtomicInteger(0);int currentValue = atomicInt.get(); // 获取当前值
int newValue = atomicInt.incrementAndGet(); // 增加1并返回新值
int updatedValue = atomicInt.addAndGet(5); // 增加5并返回新值

3. AtomicReference

AtomicReference允许在原子级别上操作引用类型的数据。它提供了getsetcompareAndSet等方法。

AtomicReference<String> atomicRef = new AtomicReference<>("initial value");String currentValue = atomicRef.get(); // 获取当前值
boolean updated = atomicRef.compareAndSet("initial value", "new value"); // 如果当前值为"initial value",则设置为"new value"

 

4. AtomicStampedReference

AtomicStampedReference是对AtomicReference的扩展,它还包含一个时间戳,用于解决ABA问题(即一个值被修改为另一个值,然后又被修改回原来的值,但是在这之间可能发生了其他的变化)。

AtomicStampedReference<String> atomicStampedRef = new AtomicStampedReference<>("initial value", 0);int currentStamp = atomicStampedRef.getStamp(); // 获取当前时间戳
String currentValue = atomicStampedRef.getReference(); // 获取当前值
boolean updated = atomicStampedRef.compareAndSet("initial value", "new value", 0, 1); // 如果当前值为"initial value"且时间戳为0,则设置为"new value"和时间戳为1

5. AtomicArray

AtomicArray类允许在原子级别上操作数组元素,提供了针对数组元素的原子更新操作。

AtomicIntegerArray atomicIntArray = new AtomicIntegerArray(5);int currentValue = atomicIntArray.get(2); // 获取索引为2的元素值
atomicIntArray.set(3, 10); // 设置索引为3的元素值为10
int updatedValue = atomicIntArray.getAndAdd(1, 5); // 增加索引为1的元素值,并返回旧值

6. AtomicReferenceFieldUpdater

AtomicReferenceFieldUpdater是Java中的一个工具类,用于进行原子更新类的引用类型字段的操作。它允许您在不使用锁的情况下对指定的引用字段进行原子操作,类似于AtomicFieldUpdater,但专门用于引用类型的字段。AtomicReferenceFieldUpdater主要用于确保在多线程环境下对引用字段的操作是线程安全的,并且可以提供更好的性能。

AtomicReferenceFieldUpdater适用于以下场景:

  1. 当您需要在不使用锁的情况下对特定类的引用字段进行原子更新时。

  2. 当引用字段的访问修饰符是volatile,以确保多线程之间的可见性。

  3. 当您希望在多个实例之间共享原子更新引用字段的功能,而不是整个对象。

要使用AtomicReferenceFieldUpdater,首先需要创建一个AtomicReferenceFieldUpdater的实例。这可以通过调用AtomicReferenceFieldUpdater.newUpdater(Class<T> tclass, Class<V> vclass, String fieldName)方法来实现,其中:

  • tclass是包含字段的类的Class对象。
  • vclass是字段的引用类型的Class对象。
  • fieldName是要进行原子操作的引用字段的名称。

以下是一个示例代码片段,演示如何创建和使用AtomicReferenceFieldUpdater实例:

public class AtomicReferenceFieldUpdaterExample {public static class Student {public volatile String name;}public static void main(String[] args) {Student student = new Student();AtomicReferenceFieldUpdater<Student, String> updater =AtomicReferenceFieldUpdater.newUpdater(Student.class, String.class, "name");updater.set(student, "Alice"); // 原子地设置name字段为"Alice"String updatedName = updater.get(student); // 原子地获取name字段的值System.out.println("Updated Name: " + updatedName);}
}

AtomicReferenceFieldUpdater提供了一系列的原子操作方法,用于对指定引用字段进行原子更新。这些方法包括:

  • boolean compareAndSet(T obj, V expect, V update):如果当前值等于expect,则将字段更新为update,返回是否更新成功。

  • V getAndSet(T obj, V newValue):将字段更新为newValue,并返回之前的值。

  • V getAndUpdate(T obj, UnaryOperator<V> updateFunction):使用给定的更新函数更新字段,并返回更新前的值。

  • V updateAndGet(T obj, UnaryOperator<V> updateFunction):使用给定的更新函数更新字段,并返回更新后的值。

  • V getAndAccumulate(T obj, V x, BinaryOperator<V> accumulatorFunction):使用给定的累加函数将字段与x进行累加操作,并返回更新前的值。

  • V accumulateAndGet(T obj, V x, BinaryOperator<V> accumulatorFunction):使用给定的累加函数将字段与x进行累加操作,并返回更新后的值。

7. LongAdder

LongAdder是Java并发包中提供的一种用于高并发场景下对long类型进行累加操作的工具类。与传统的AtomicLong相比,LongAdder在高并发情况下通常能够提供更好的性能,因为它采用了一种分段的方式来减少竞争。LongAdder的引入主要是为了应对高并发累加操作的性能瓶颈,特别是在多核处理器上。

LongAdder在高并发场景下的主要优势在于分段累加,以及对热点数据的分离处理。传统的AtomicLong在高并发情况下可能会因为多线程之间的竞争而导致性能下降,而LongAdder通过将累加操作分成多个段,每个段维护一个计数器,从而减少了竞争。

另外,LongAdder还引入了一种称为“分离器”(Cell)的机制。分离器是计数器的基本单元,每个线程在累加时会选择一个分离器进行操作,这避免了多线程频繁地竞争同一个计数器,从而减少了竞争带来的开销。

要使用LongAdder,只需要简单地创建一个LongAdder的实例即可:

LongAdder longAdder = new LongAdder();

 

LongAdder提供了一些常用的方法来进行累加操作:

  • void add(long x):将指定的值添加到计数器中。

  • void increment():将计数器增加1。

  • void decrement():将计数器减少1。

  • long sum():返回当前计数器的总和。

  • void reset():将计数器重置为0。

  • void addThenReset(long x):将指定的值添加到计数器中,然后将计数器重置为0。

原子类的使用注意事项

  1. 性能考虑: 虽然原子类可以提供一定程度的性能优势,但并不是适用于所有情况。在高并发场景下,考虑使用原子类;而在低并发、性能要求不高的情况下,可能传统的同步机制更加合适。

  2. CAS操作的限制: 原子类的底层实现主要依赖于CAS(Compare-And-Swap)操作,这是一种乐观锁机制。然而,CAS操作可能会在竞争激烈的情况下导致自旋等待,影响性能。

  3. ABA问题: 原子类的CAS操作可能存在ABA问题,即一个值从A变为B,然后又从B变为A,这时CAS操作可能会错误地认为值没有发生变化。可以使用AtomicStampedReference来解决此问题。

  4. 复合操作的原子性: 原子类的单个操作是原子的,但多个操作的组合并不一定是原子的。例如,AtomicIntegerincrementAndGet操作是原子的,但在使用时仍然需要考虑复合操作的原子性。

  5. 适用范围: 原子类适用于简单的原子操作,但并不适用于复杂的业务逻辑。对于复杂的操作,可能需要使用锁等更高级的同步机制来确保线程安全。

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

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

相关文章

UDP通信实验、广播与组播、本地套接字

文章目录 流程函数应用广播应用 组播&#xff08;多播&#xff09;本地套接字应用 流程 函数 返回值&#xff1a; 成功&#xff0c;返回成功发送的数据长度 失败&#xff0c;-1 返回值&#xff1a; 成功&#xff0c;返回成功接收数据长度 失败&#xff0c;-1 应用 广播 应用 …

MongoDB文档-进阶使用-MongoDB索引-createindex()与dropindex()-在MongoDB中使用正则表达式来查找

阿丹&#xff1a; 之前研究了MongoDB的基础增删改查。在学会基础的数据库增删改查肯定是不够的。这个时候就涉及到了数据库搜索的时候的效率。需要提高数据的搜索效率。 MongoDB索引 在所以数据库中如果没有数据索引的时候。如果需要查找到一些数据。都会去主动扫描所有可能存…

Arduino驱动MiCS-2714氢气和氮氧化物气体传感器(气体传感器篇)

目录 1、传感器特性 2、硬件原理图 3、控制器和传感器连线图 4、驱动程序

mybatis-plus的逻辑删除的坑

一旦在逻辑字段上加了TableLogic逻辑删除的配置&#xff0c;并且使用mybatis-plus自带的方法时&#xff08;如果自己用xml写SQL不会出现下面的情况&#xff09; 查询、修改时会自动排除逻辑删除的数据 当使用mybatis-plus自带的查询方法时&#xff0c;就不用每次查询的时候跟…

Blazor 简单组件(1):B_Icon开发

文章目录 前言ICON开发使用 前言 Blazor 简单组件(0)&#xff1a;简单介绍 ICON开发 <i class"Type" style"font-size:(Size)px;color:Color;"></i>code {/// <summary>/// icon类型/// </summary>[Parameter]public string Typ…

nginx 以及nginx优化

目录 nginx功能介绍 静态文件服务 反向代理 动态内容处理 SSL/TLS 加密支持 虚拟主机支持 URL 重写和重定向 缓存机制 日志记录 可扩展性和灵活性 nginx的主要应用场景 nginx常用命令 nginx另外一种安装方式 nginx常用的信号符&#xff1a; nginx配置文件详解 n…

Nginx复现

docker复现Nginx配置漏洞 2.1CRLF(carriage return/line feed)注入漏洞 这个漏洞产生的原因是请求重定向的错误配置&#xff0c;导致在url中输入回车换行符可以控制http响应头部 比如&#xff1a;location / { return 302 https://$host$uri; } 原本的目的是为了让http的…

【JavaEE基础学习打卡02】是时候了解JavaEE了

目录 前言一、为什么要学习JavaEE二、JavaEE规范介绍1.什么是规范&#xff1f;2.什么是JavaEE规范&#xff1f;3.JavaEE版本 三、JavaEE应用程序模型1.模型前置说明2.模型具体说明 总结 前言 &#x1f4dc; 本系列教程适用于JavaWeb初学者、爱好者&#xff0c;小白白。我们的天…

c#在设计时调试自定义 Windows 窗体控件

private string demoStringValue null; [Browsable(true)] public string DemoString {get{return this.demoStringValue;}set{demoStringValue value;} } 参考链接 在设计时调试自定义控件 - Windows Forms .NET Framework | Microsoft Learnhttps://learn.microsoft.com/z…

生信豆芽菜——配对型的复杂箱线图使用说明

网站&#xff1a;http://www.sxdyc.com/visualsBoxHalfPlot 一、配对型的复杂箱线图简介 配对型的复杂箱线图原理与箱线图相同&#xff0c;常见于配对样本的数据分析中&#xff0c;在日常研究中&#xff0c;我们会碰到配对资料&#xff0c;例如同一病人治疗前后的变化&#xff…

数据结构: 线性表(带头双向循环链表实现)

之前一章学习了单链表的相关操作, 但是单链表的限制却很多, 比如不能倒序扫描链表, 解决方法是在数据结构上附加一个域, 使它包含指向前一个单元的指针即可. 那么怎么定义数据结构呢? 首先我们先了解以下链表的分类 1. 链表的分类 链表的结构非常多样, 以下情况组合起来就有…

LVS集群

目录 1、lvs简介&#xff1a; 2、lvs架构图&#xff1a; 3、 lvs的工作模式&#xff1a; 1&#xff09; VS/NAT&#xff1a; 即&#xff08;Virtual Server via Network Address Translation&#xff09; 2&#xff09;VS/TUN &#xff1a;即&#xff08;Virtual Server v…

7.2 手撕VGG11模型 使用Fashion_mnist数据训练VGG

VGG首先引入块的思想将模型通用模板化 VGG模型的特点 与AlexNet&#xff0c;LeNet一样&#xff0c;VGG网络可以分为两部分&#xff0c;第一部分主要由卷积层和汇聚层组成&#xff0c;第二部分由全连接层组成。 VGG有5个卷积块&#xff0c;前两个块包含一个卷积层&#xff0c…

P8604 [蓝桥杯 2013 国 C] 危险系数

题目背景 抗日战争时期&#xff0c;冀中平原的地道战曾发挥重要作用。 题目描述 地道的多个站点间有通道连接&#xff0c;形成了庞大的网络。但也有隐患&#xff0c;当敌人发现了某个站点后&#xff0c;其它站点间可能因此会失去联系。 我们来定义一个危险系数 DF(x,y)&…

MySQL_SQL性能分析

SQL执行频次 语法&#xff1a; SHOW GLOBAL STATUS LIKE COM_类型; COM_insert; 插入次数 com_delete; 删除次数 com_update; 更新次数 com_select; 查询次数 com_______; 注意&#xff1a;通过语法&#xff0c;可以查询到数据库的实际状态&#xff0c;就可以知道数据库是以增删…

TDesign中后台管理系统-用户登录

目录 1 创建用户表2 开发后端接口3 测试接口4 修改登录页面调用后端接口最终效果总结 中后台系统第一个要实现的功能就是登录了&#xff0c;我们通常的逻辑是让用户在登录页面输入用户名和密码&#xff0c;调用后端接口去验证用户的合法性&#xff0c;然后根据接口返回的结果进…

【T3】金蝶kis凭证数据转换到畅捷通T3软件中。

【问题需求】 将金蝶软件中的账套转换到畅捷通T3软件中。 由于金蝶老版本使用的是非sql server数据库。 进而需要将其数据导入到sql中,在转换到T3。 【转换环境】 金蝶中数据:凭证;科目无项目核算。 1、金蝶的数据文件后缀为.AIS; 2、安装office2003全版软件; 3、安装sq…

【算法】双指针——leetcode盛最多水的容器、剑指Offer57和为s的两个数字

盛水最多的容器 &#xff08;1&#xff09;暴力解法 算法思路&#xff1a;我们枚举出所有的容器大小&#xff0c;取最大值即可。 容器容积的计算方式&#xff1a; 设两指针 i , j &#xff0c;分别指向水槽板的最左端以及最右端&#xff0c;此时容器的宽度为 j - i 。由于容器…

【CDH集群】无法发出查询:Host Monitor未运行

无法发出查询:Host Monitor未运行 【CDH集群】无法发出查询:Host Monitor未运行同事的解决方案解决方法&#xff1a;删除原uuid重启agent查看新uuid修改scm数据库中HOSTS表中的agent的uuid 【CDH集群】无法发出查询:Host Monitor未运行 起初是impala报错&#xff0c;连接不上&…

使用 React Native CLI 创建项目

React Native 安装的先决条件和设置 需要掌握的知识点 掌握 JavaScript 基础知识掌握 React 相关基础知识掌握 TypeScript 相关基础知识 安装软件前需要首先安装Chocolatey。Chocolatey 是一种流行的 Windows 包管理器。 安装 nodejs 和 JDK choco install -y nodejs-lts …