欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 新闻 > 焦点 > 原子类(Atomic Classes)

原子类(Atomic Classes)

2024/12/28 3:02:22 来源:https://blog.csdn.net/m0_73837751/article/details/143083314  浏览:    关键词:原子类(Atomic Classes)

在多线程环境中,原子类(Atomic Classes)是专门设计用于解决并发问题的类,它们能够确保对共享变量的操作是原子性的(不可中断),从而避免线程安全问题。Java 提供了一系列原子类,主要位于 java.util.concurrent.atomic 包中,这些原子类通过无锁的方式来确保并发操作的安全性和高效性。

1. 什么是原子性操作?

原子性操作指的是操作要么完全执行,要么完全不执行。操作的中间状态对其他线程不可见。原子操作不能被其他线程打断或影响。例如:

  • 读取一个整数是一个原子操作。
  • 对整数进行自增操作(count++)在多线程环境下不是原子操作,因为它实际上由三个步骤组成:读取值、增加值、写回内存。在这些步骤中,如果其他线程并发操作相同的值,可能会导致数据不一致。

2. 为什么需要原子类?

在多线程编程中,操作共享资源的常见方式是加锁(例如 synchronizedLock),但加锁会带来性能开销,尤其是在高并发场景下。为了解决这一问题,Java 提供了一系列原子类,它们通过使用无锁机制(例如 CAS,Compare-And-Swap,比较并交换)来保证操作的原子性和线程安全性。

原子类避免了使用传统的锁,从而提供了更好的性能,并且降低了死锁等并发问题的风险。

3. 常见的原子类

Java 中的原子类主要用于操作基本数据类型(如 intlong)和引用类型,常见的原子类有:

  • AtomicInteger:用于对 int 类型的变量进行原子操作。
  • AtomicLong:用于对 long 类型的变量进行原子操作。
  • AtomicBoolean:用于对 boolean 类型的变量进行原子操作。
  • AtomicReference<T>:用于对引用类型的变量进行原子操作。

4. AtomicInteger 示例

AtomicInteger 是最常用的原子类之一,用于对 int 类型的变量执行原子性操作。它提供了一些线程安全的操作方法,如 incrementAndGet()(原子性自增)、decrementAndGet()(原子性自减)、compareAndSet()(原子性比较和设置)等。

示例:使用 AtomicInteger 实现线程安全的自增

import java.util.concurrent.atomic.AtomicInteger;public class AtomicCounter {// 使用 AtomicInteger 保证线程安全private AtomicInteger count = new AtomicInteger(0);// 原子性自增操作public void increment() {count.incrementAndGet();  // 无锁的线程安全自增}// 获取当前计数值public int getCount() {return count.get();  // 无锁的线程安全读取}public static void main(String[] args) {AtomicCounter counter = new AtomicCounter();// 创建多个线程并发执行自增操作for (int i = 0; i < 10; i++) {new Thread(counter::increment).start();}// 主线程睡眠一段时间,以确保所有子线程完成执行try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}// 打印最终的计数结果System.out.println("最终计数值:" + counter.getCount());}
}

解释

  • AtomicInteger:通过 AtomicInteger 来替代传统的 int,确保 incrementAndGet() 操作是原子性的,不会因为多个线程并发修改 count 而导致数据不一致。
  • 无锁机制AtomicInteger 通过 CAS(比较并交换)机制保证线程安全,而不需要使用锁,从而在高并发环境下有更好的性能表现。

原子性操作方法

  • incrementAndGet():原子性地自增,并返回递增后的值。
  • get():原子性地获取当前值。
  • compareAndSet(expectedValue, newValue):如果当前值等于 expectedValue,则将其设置为 newValue,这是 CAS 操作的核心。

5. AtomicReference<T> 示例

AtomicReference 是用于操作引用类型(如对象)的原子类,它可以确保在多线程环境中安全地修改对象引用。AtomicReference 主要提供了原子性的读写、比较和设置引用的方法。

AtomicReference<T> 提供了以下常用操作:

  • get():获取当前存储的对象引用。
  • set(T newValue):设置新的对象引用。
  • compareAndSet(T expect, T update):比较当前引用是否等于 expect,如果相等,则将引用设置为 update

设置引用类型

 private AtomicReference<List<String>> atomicList = new AtomicReference<>(new ArrayList<>());
  •  无论是数组,还是类的对象,我们都需要在等式左边去定义一个数组或对象,然后在等式右边通过new来去创建数组或对象,右边创建的会被左边定义的所引用。
  • 这里的使用方式与上面提到类似,也是要在左边的AtomicReference<>的<>内去定义某种类型,然后在右边的new AtomicReference<>(),在()中去通过new 来创建,然后被左边的atomicList所引用。

示例:引用自定义对象类型

import java.util.concurrent.atomic.AtomicReference;class User {private String name;private int age;public User(String name, int age) {this.name = name;this.age = age;}@Overridepublic String toString() {return "User{name='" + name + "', age=" + age + "}";}
}public class AtomicUserExample {private AtomicReference<User> atomicUser = new AtomicReference<>(new User("初始用户", 30));public void updateUser(User newUser) {atomicUser.set(newUser);  // 线程安全地更新用户对象引用}public User getUser() {return atomicUser.get();  // 线程安全地获取用户对象引用}public boolean compareAndSetUser(User expectedUser, User newUser) {return atomicUser.compareAndSet(expectedUser, newUser);  // 线程安全地比较和更新用户对象引用}public static void main(String[] args) {AtomicUserExample example = new AtomicUserExample();// 获取并打印当前用户System.out.println("当前用户:" + example.getUser());// 更新用户信息example.updateUser(new User("新用户", 25));// 获取并打印更新后的用户System.out.println("更新后的用户:" + example.getUser());}
}

 示例:引用List<T> 类型

import java.util.concurrent.atomic.AtomicReference;
import java.util.List;
import java.util.ArrayList;public class AtomicListExample {private AtomicReference<List<String>> atomicList = new AtomicReference<>(new ArrayList<>());public void addToList(String value) {List<String> currentList, newList;do {currentList = atomicList.get();  // 获取当前的列表引用newList = new ArrayList<>(currentList);  // 复制列表newList.add(value);  // 添加元素} while (!atomicList.compareAndSet(currentList, newList));  // 比较并设置新的列表}public List<String> getList() {return atomicList.get();  // 线程安全地获取列表}public static void main(String[] args) {AtomicListExample example = new AtomicListExample();// 向列表中添加值example.addToList("值1");example.addToList("值2");// 获取并打印列表System.out.println("列表内容:" + example.getList());}
}

6. CAS(Compare-And-Swap)机制

CAS(Compare-And-Swap,比较并交换) 是原子类实现线程安全的核心机制。它的基本思想是:在修改一个变量时,先检查该变量当前的值是否等于预期值。如果相等,才执行修改操作;如果不相等,说明其他线程已经修改了该变量,此时不执行修改,而是重新尝试操作。

CAS 操作步骤

  1. 读取变量当前的值。
  2. 判断该值是否等于预期值(例如上次读取的值)。
  3. 如果相等,执行修改操作;如果不相等,则放弃修改,重新获取变量的最新值,并再次进行尝试。

通过 CAS 机制,原子类可以在高并发环境下避免使用锁,从而提升并发性能。

CAS 机制的缺点

  • ABA 问题:如果一个变量的值从 A 变成 B,然后又变回 A,CAS 操作无法检测到这个变化,这可能会导致数据不一致。为了解决这个问题,Java 提供了 AtomicStampedReference,它为每个变量的值增加了一个版本号,用于跟踪变量的变化。

    示例:使用 AtomicStampedReference 解决 ABA 问题

7. 使用原子类的优势

  • 无锁机制:原子类使用 CAS 机制,不依赖锁来保证线程安全,因此在高并发场景下比加锁方案具有更好的性能。
  • 简洁易用:原子类提供了简洁的接口,可以方便地执行原子操作,减少了手动加锁的复杂性。
  • 适用于高并发场景:原子类非常适合在高并发场景下频繁执行的简单操作(如计数、状态更新等),如计数器、并发控制等。

总结

  • 原子类 是 Java 并发工具包中的核心工具,提供了一系列无锁的原子操作,用于替代传统的锁机制。
  • 主要原子类:如 AtomicIntegerAtomicReference 等,提供了线程安全的基本类型操作和引用操作,适用于高并发环境下的简单操作。
  • CAS 机制 是原子类的核心,通过比较并交换来保证操作的原子性,但需要注意 ABA 问题。

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com