在多线程环境中,原子类(Atomic Classes)是专门设计用于解决并发问题的类,它们能够确保对共享变量的操作是原子性的(不可中断),从而避免线程安全问题。Java 提供了一系列原子类,主要位于 java.util.concurrent.atomic
包中,这些原子类通过无锁的方式来确保并发操作的安全性和高效性。
1. 什么是原子性操作?
原子性操作指的是操作要么完全执行,要么完全不执行。操作的中间状态对其他线程不可见。原子操作不能被其他线程打断或影响。例如:
- 读取一个整数是一个原子操作。
- 对整数进行自增操作(
count++
)在多线程环境下不是原子操作,因为它实际上由三个步骤组成:读取值、增加值、写回内存。在这些步骤中,如果其他线程并发操作相同的值,可能会导致数据不一致。
2. 为什么需要原子类?
在多线程编程中,操作共享资源的常见方式是加锁(例如 synchronized
或 Lock
),但加锁会带来性能开销,尤其是在高并发场景下。为了解决这一问题,Java 提供了一系列原子类,它们通过使用无锁机制(例如 CAS,Compare-And-Swap,比较并交换)来保证操作的原子性和线程安全性。
原子类避免了使用传统的锁,从而提供了更好的性能,并且降低了死锁等并发问题的风险。
3. 常见的原子类
Java 中的原子类主要用于操作基本数据类型(如 int
、long
)和引用类型,常见的原子类有:
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 操作步骤:
- 读取变量当前的值。
- 判断该值是否等于预期值(例如上次读取的值)。
- 如果相等,执行修改操作;如果不相等,则放弃修改,重新获取变量的最新值,并再次进行尝试。
通过 CAS 机制,原子类可以在高并发环境下避免使用锁,从而提升并发性能。
CAS 机制的缺点:
-
ABA 问题:如果一个变量的值从 A 变成 B,然后又变回 A,CAS 操作无法检测到这个变化,这可能会导致数据不一致。为了解决这个问题,Java 提供了
AtomicStampedReference
,它为每个变量的值增加了一个版本号,用于跟踪变量的变化。示例:使用
AtomicStampedReference
解决 ABA 问题
7. 使用原子类的优势
- 无锁机制:原子类使用 CAS 机制,不依赖锁来保证线程安全,因此在高并发场景下比加锁方案具有更好的性能。
- 简洁易用:原子类提供了简洁的接口,可以方便地执行原子操作,减少了手动加锁的复杂性。
- 适用于高并发场景:原子类非常适合在高并发场景下频繁执行的简单操作(如计数、状态更新等),如计数器、并发控制等。
总结
- 原子类 是 Java 并发工具包中的核心工具,提供了一系列无锁的原子操作,用于替代传统的锁机制。
- 主要原子类:如
AtomicInteger
、AtomicReference
等,提供了线程安全的基本类型操作和引用操作,适用于高并发环境下的简单操作。 - CAS 机制 是原子类的核心,通过比较并交换来保证操作的原子性,但需要注意 ABA 问题。