AtomicReferenceArray提供线程安全的对象数组原子操作,基于CAS和volatile语义实现元素级并发控制,适用于高并发下无锁更新数组元素的场景。
在Java中,AtomicReferenceArray 是 java.util.concurrent.atomic 包提供的一个线程安全的数组类,用于对对象数组的元素进行原子性更新。它适用于需要在多线程环境下安全地读取和修改数组元素的场景,而无需使用 synchronized 或显式锁。
与普通的数组不同,AtomicReferenceArray 提供了基于 volatile 语义和 CAS(Compare-And-Swap)机制的方法来保证单个元素操作的原子性。它不支持数组整体的原子操作,但能确保每个索引位置的读写是线程安全的。
可以通过指定大小或从已有数组复制来创建实例:
// 创建一个长度为10的空数组 AtomicReferenceArrayarray = new AtomicReferenceArray<>(10); // 使用已有数组初始化(会复制内容) String[] init = {"a", "b", "c"}; AtomicReferenceArray array2 = new AtomicReferenceArray<>(init);
以下是一些核心方法及其用途:
假设我们有一个共享的状态数组,多个线程需要更新某个位置的状态:
AtomicReferenceArraystates = new AtomicReferenceArray<>(5); // 线程1尝试更新索引2的状态 boolean success = states.compareAndSet(2, null, "RUNNING"); if (success) { System.out.println("状态设置成功"); } else { System.out.println("状态已被其他线程修改"); } // 线程2安全读取 String current = states.get(2); System.out.println("当前状态:" + current); // 原子交换 String old = states.getAndSet(2, "FINISHED"); System.out.println("旧状态:" + old);
这个例子展示了如何通过 compareAndSet 避免竞态条件,比如只在状态为空时才设置为运行中。
AtomicReferenceArray 特别适合以下情况:
需要注意: