Java中CAS算法的集中体现:Atomic原子类库,你了解吗?

简介: 【5月更文挑战第15天】Java中CAS算法的集中体现:Atomic原子类库,你了解吗?

一、写在开头

在前面的博文中我们学习了volatile关键字,知道了它可以保证有序性和可见性,但无法保障原子性,结局原子性问题推荐使用synchronized、Lock或者AtomicInteger;我们还学习过CAS算法,在那篇博文中我们同样也提及atomic。那么今天,我们就来好好学一学Atomic原子库,一个基于CAS算法实现的高效并发工具库

并发包 java.util.concurrent 的原子类都存放在java.util.concurrent.atomic中,如下图所示:

atomic.png

1.1 Atomic释义

Atomic翻译为“原子”,何为原子?在化学领域的原子被认为是构成化学反应的最小微观粒子,是不可分割的最小单位(当然后面又发现了更小的粒子,咱们不杠哈),伟大的Doug Lea大师,将并发的一些类以此单词开头命名,一语中的!

  • 原子性在程序中所表达的意思是:一个或者多个操作在 CPU 执行的过程中不被中断的特性!
  • 原子操作在程序中表达的意思是:即最小不可拆分的操作,也就是说操作一旦开始,就不能被打断,直到操作完成!

二、四大原子分类

我们根据操作的数据类型可以将JUC包中的原子类做如下的4种划分:

2.1 基本类型

原子操作的基本类型主要可分为:

  1. AtomicBoolean:布尔型原子类;
  2. AtomicInteger:整型原子类;
  3. AtomicLong:长整型原子类;

这三种方式用法几乎相同,都是以原子更新的方式操作基本类型,我们在这里以AtomicInteger为例看一下它的使用与原理。

1)AtomicInteger的常用方法

public final int get() //获取当前的值
public final int getAndSet(int newValue)//获取当前的值,并设置为newValue
public final int getAndIncrement()//获取当前的值,并自增
public final int incrementAndGet()//增加 1,并获取新值,注意与上面方法区分
public final int getAndDecrement() //获取当前的值,并自减
public final int getAndAdd(int delta) //获取当前的值,并加上预期的值delta
boolean compareAndSet(int expect, int update) //如果输入的数值等于预期值,则以原子方式将该值设置为输入值(update)
public final void lazySet(int newValue)//最终设置为newValue,使用 lazySet 设置之后可能导致其他线程在之后的一小段时间内还是可以读到旧的值。
AI 代码解读

2)AtomicInteger的使用案例

public class Test {
   
    public static void main(String[] args) {
   
        //临时值
        int temvalue = 0;
        AtomicInteger i = new AtomicInteger(0);
        temvalue = i.getAndSet(3);
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:0;  i:3
        temvalue = i.getAndIncrement();
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:3;  i:4
        temvalue = i.getAndAdd(5);
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:4;  i:9
        temvalue = i.incrementAndGet();
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:10;  i:10
    }
}
AI 代码解读

这里面需要注意的一点是getAndIncrement()方法与incrementAndGet(),一个先获值后自增,一个先自增后获值。

3)AtomicInteger的底层原理

我们以getAndIncrement()为例,去跟入它的底层代码会发现,其内部是同调佣UnSafe类的静态方法 getUnsafe 实现的,UnSafe类我们在讲解CAS算法的时候有提及,后面找个时间再单独学一下它,其底层是通过CAS,原子性的进行增加值。

public final int getAndIncrement() {
   
    // 使用Unsafe类中的getAndAddInt方法原子地增加AtomicInteger的当前值
    // 第一个参数this是AtomicInteger的当前实例
    // 第二个参数valueOffset是一个偏移量,它指示在AtomicInteger对象中的哪个位置可以找到实际的int值
    // 第三个参数1表示要加到当前值上的值(即增加的值)
    // 此方法返回的是增加前的原始值
    return unsafe.getAndAddInt(this, valueOffset, 1);
}
AI 代码解读

Unsafe 类是 Java 中的一个特殊类,用于执行低级、不安全的操作。getAndIncrement 方法就是利用了 Unsafe 类提供的 CAS(Compare-And-Swap)操作来实现原子的 increment 操作。CAS 是一种常用的无锁技术,允许在多线程环境中原子地更新值。

2.2 数组类型

原子操作根据数组类型,可以分为如下几种:

  1. AtomicIntegerArray:整形数组原子类
  2. AtomicLongArray:长整形数组原子类
  3. AtomicReferenceArray:引用类型数组原子类

这三种同样很类似,我们以AtomicIntegerArray为例来介绍一下。

1)AtomicIntegerArray的常用方法

public final int get(int i) //获取 index=i 位置元素的值
public final int getAndSet(int i, int newValue)//返回 index=i 位置的当前的值,并将其设置为新值:newValue
public final int getAndIncrement(int i)//获取 index=i 位置元素的值,并让该位置的元素自增
public final int getAndDecrement(int i) //获取 index=i 位置元素的值,并让该位置的元素自减
public final int getAndAdd(int i, int delta) //获取 index=i 位置元素的值,并加上预期的值
boolean compareAndSet(int i, int expect, int update) //如果输入的数值等于预期值,则以原子方式将 index=i 位置的元素值设置为输入值(update)
public final void lazySet(int i, int newValue)//最终 将index=i 位置的元素设置为newValue,使用 lazySet 设置之后可能导致其他线程在之后的一小段时间内还是可以读到旧的值。
AI 代码解读

2)AtomicIntegerArray的使用案例

public class Test {
   
    public static void main(String[] args) {
   
        int temvalue = 0;
        int[] nums = {
    1, 2, 3, 4, 5, 6 };
        AtomicIntegerArray i = new AtomicIntegerArray(nums);
        for (int j = 0; j < nums.length; j++) {
   
            System.out.print(i.get(j));
        }
        System.out.println();
        temvalue = i.getAndSet(0, 2);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
        temvalue = i.getAndIncrement(0);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
        temvalue = i.getAndAdd(0, 5);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
    }
}
AI 代码解读

输出:

123456
temvalue:1;  i:[2, 2, 3, 4, 5, 6]
temvalue:2;  i:[3, 2, 3, 4, 5, 6]
temvalue:3;  i:[8, 2, 3, 4, 5, 6]
AI 代码解读

2.3 引用类型

除了如上的2种原子类外,atomic包中还提供了引用类型原子类。大概为如下几种:

  1. AtomicReference:原子更新引用类型,使用AtomicReference类保证对象之间的原子性,把多个变量放到一个对象里面进行 CAS 操作;
  2. AtomicStampedReference:原子更新带有版本号的引用类型。该类将整数值与引用关联起来,可用于解决原子的更新数据和数据的版本号,可以解决使用 CAS 进行原子更新时可能出现的 ABA 问题;
  3. AtomicMarkableReference:原子更新带有标记的引用类型,该类将 boolean 标记与引用关联起来。

常用方法又上述两种类型一致,这里不再赘述,我们直接写一个demo感受一下它的使用吧

public class TestAtomicReference {
   

    private static AtomicReference<User> reference = new AtomicReference<>();

    public static void main(String[] args) {
   
        User user1 = new User("小明", 18);
        reference.set(user1);
        User user2 = new User("小华",20);
        User user = reference.getAndSet(user2);
        System.out.println(user);
        System.out.println(reference.get());
    }

    static class User {
   
        private String userName;
        private int age;

        public User(String userName, int age) {
   
            this.userName = userName;
            this.age = age;
        }

        @Override
        public String toString() {
   
            return "User{" +
                    "userName='" + userName + '\'' +
                    ", age=" + age +
                    '}';
        }
    }
}
AI 代码解读

输出:

User{
   userName='小明', age=18}
User{
   userName='小华', age=20}
AI 代码解读

通过结果我们可以看出先给该reference引用对象set一个user1,再通过getAndSet()方法进行赋值,先输出当前对象数据,紧接着引用指向最新的对象地址,也就是“User{userName='小华', age=20}”。

2.4 对象的属性修改类型

除了原子更新对象(引用类型)外,atomic中还提供了更新对象的属性字段的原子类:

  1. AtomicIntegerFieldUpdater:原子更新整形字段的更新器;
  2. AtomicLongFieldUpdater:原子更新长整形字段的更新器;
  3. AtomicReferenceFieldUpdater:原子更新引用类型里的字段的更新器。

如果想要原子的更新对象的属性,实现起来较上面几种类型略微复杂一下,大概分为两步;

步骤1️⃣
通过静态方法newUpdater创建一个更新器,并且设置想要更新的类和字段;

步骤2️⃣
字段必须使用public volatile进行修饰;

以 AtomicIntegerFieldUpdater为例,我们写一个测试类感受一下。

public class TestAtomicIntegerFieldUpdater {
   
    //创建一个age的更新器
    private static AtomicIntegerFieldUpdater updater = AtomicIntegerFieldUpdater.newUpdater(User.class,"age");

    public static void main(String[] args) {
   
        User user = new User("小明", 17);
        int oldValue = updater.getAndAdd(user, 1);
        System.out.println(oldValue);//17
        System.out.println(updater.get(user));//18
    }

    static class User {
   
        private String userName;
        public volatile int age;

        public User(String userName, int age) {
   
            this.userName = userName;
            this.age = age;
        }

        @Override
        public String toString() {
   
            return "User{" +
                    "userName='" + userName + '\'' +
                    ", age=" + age +
                    '}';
        }
    }
AI 代码解读

通过AtomicIntegerFieldUpdater.newUpdater(User.class,"age")创建一个age的更新器,然后调用getAndAdd(user, 1)进行年龄加1操作,从17岁变为18岁。

三、结尾彩蛋

如果本篇博客对您有一定的帮助,大家记得留言+点赞+收藏呀。原创不易,转载请联系Build哥!

目录
打赏
0
1
1
0
66
分享
相关文章
探究‘公司禁用 U 盘’背后的哈希表算法与 Java 实现
在数字化办公时代,信息安全至关重要。许多公司采取“禁用U盘”策略,利用哈希表算法高效管理外接设备的接入权限。哈希表通过哈希函数将设备标识映射到数组索引,快速判断U盘是否授权。例如,公司预先将允许的U盘标识存入哈希表,新设备接入时迅速验证,未授权则禁止传输并报警。这有效防止恶意软件和数据泄露,保障企业信息安全。 代码示例展示了如何用Java实现简单的哈希表,模拟公司U盘管控场景。哈希表不仅用于设备管理,还在文件索引、用户权限等多方面助力信息安全防线的构建,为企业数字化进程保驾护航。
Java 实现局域网电脑屏幕监控算法揭秘
在数字化办公环境中,局域网电脑屏幕监控至关重要。本文介绍用Java实现这一功能的算法,涵盖图像采集、数据传输和监控端显示三个关键环节。通过Java的AWT/Swing库和Robot类抓取屏幕图像,使用Socket进行TCP/IP通信传输图像数据,并利用ImageIO类在监控端展示图像。整个过程确保高效、实时和准确,为提升数字化管理提供了技术基础。
104 15
解锁“分享文件”高效密码:探秘 Java 二叉搜索树算法
在信息爆炸的时代,文件分享至关重要。二叉搜索树(BST)以其高效的查找性能,为文件分享优化提供了新路径。本文聚焦Java环境下BST的应用,介绍其基础结构、实现示例及进阶优化。BST通过有序节点快速定位文件,结合自平衡树、多线程和权限管理,大幅提升文件分享效率与安全性。代码示例展示了文件插入与查找的基本操作,适用于大规模并发场景,确保分享过程流畅高效。掌握BST算法,助力文件分享创新发展。
解锁分布式文件分享的 Java 一致性哈希算法密码
在数字化时代,文件分享成为信息传播与协同办公的关键环节。本文深入探讨基于Java的一致性哈希算法,该算法通过引入虚拟节点和环形哈希空间,解决了传统哈希算法在分布式存储中的“哈希雪崩”问题,确保文件分配稳定高效。文章还展示了Java实现代码,并展望了其在未来文件分享技术中的应用前景,如结合AI优化节点布局和区块链增强数据安全。
Java线程调度揭秘:从算法到策略,让你面试稳赢!
在社招面试中,关于线程调度和同步的相关问题常常让人感到棘手。今天,我们将深入解析Java中的线程调度算法、调度策略,探讨线程调度器、时间分片的工作原理,并带你了解常见的线程同步方法。让我们一起破解这些面试难题,提升你的Java并发编程技能!
110 16
企业局域网监控软件中 Java 优先队列算法的核心优势
企业局域网监控软件是数字化时代企业网络安全与高效运营的基石,犹如一位洞察秋毫的卫士。通过Java实现的优先队列算法,它能依据事件优先级排序,确保关键网络事件如异常流量、数据泄露等被优先处理,保障系统稳定与安全。代码示例展示了如何定义网络事件类并使用PriorityQueue处理高优先级事件,尤其在面对疑似风险时迅速启动应急措施。这一核心技术助力企业在复杂网络环境中稳健前行,护航业务腾飞。
72 32
剖析基于Java算法驱动的智能局域网管控之道
本文探讨了基于Java语言的局域网控制方案,结合链表数据结构与令牌桶算法,解决设备管理和流量调度难题。通过链表灵活存储网络设备信息,实现高效设备管理;令牌桶算法则精准控制流量,确保网络平稳运行。二者相辅相成,为校园、企业等局域网提供稳固高效的控制体系,保障业务连续性和数据安全。
【潜意识Java】深度解析黑马项目《苍穹外卖》与蓝桥杯算法的结合问题
本文探讨了如何将算法学习与实际项目相结合,以提升编程竞赛中的解题能力。通过《苍穹外卖》项目,介绍了订单配送路径规划(基于动态规划解决旅行商问题)和商品推荐系统(基于贪心算法)。这些实例不仅展示了算法在实际业务中的应用,还帮助读者更好地准备蓝桥杯等编程竞赛。结合具体代码实现和解析,文章详细说明了如何运用算法优化项目功能,提高解决问题的能力。
91 6
【潜意识Java】蓝桥杯算法有关的动态规划求解背包问题
本文介绍了经典的0/1背包问题及其动态规划解法。
69 5
理解CAS算法原理
CAS(Compare and Swap,比较并交换)是一种无锁算法,用于实现多线程环境下的原子操作。它通过比较内存中的值与预期值是否相同来决定是否进行更新。JDK 5引入了基于CAS的乐观锁机制,替代了传统的synchronized独占锁,提升了并发性能。然而,CAS存在ABA问题、循环时间长开销大和只能保证单个共享变量原子性等缺点。为解决这些问题,可以使用版本号机制、合并多个变量或引入pause指令优化CPU执行效率。CAS广泛应用于JDK的原子类中,如AtomicInteger.incrementAndGet(),利用底层Unsafe库实现高效的无锁自增操作。
134 0
理解CAS算法原理

热门文章

最新文章