当前位置：首页 > 文章列表 > 文章 > java教程 > AtomicReference引用类型详解与应用

AtomicReference引用类型详解与应用

2025-10-19 09:44:30 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《Java中AtomicReference引用类型使用详解》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

AtomicReference提供线程安全的引用更新，通过get、set和compareAndSet等方法实现无锁操作，适用于状态切换、配置管理等场景，但需注意被引用对象本身的线程安全性，推荐结合不可变对象使用以确保整体安全。

在Java中如何使用AtomicReference处理引用类型

在Java中，AtomicReference 是 java.util.concurrent.atomic 包提供的一个原子类，用于对引用类型进行线程安全的操作。它允许你以原子方式更新对象的引用，避免使用 synchronized 关键字就能实现线程安全。

AtomicReference 的基本用法

AtomicReference 可以包装任何引用类型的对象（如自定义对象、集合、字符串等），并提供一系列原子操作方法：

get()：获取当前引用值
set(newValue)：设置新引用（非原子比较）
compareAndSet(expect, update)：如果当前引用等于 expect，则更新为 update，成功返回 true
weakCompareAndSet(...)：弱版本的 CAS，不保证指令有序性（已过时，推荐使用 compareAndSet）

示例代码：

import java.util.concurrent.atomic.AtomicReference;
<p>class Person {
private String name;
private int age;</p><pre class="brush:php;toolbar:false"><code>public Person(String name, int age) {
    this.name = name;
    this.age = age;
}

// getter 方法
public String getName() { return name; }
public int getAge() { return age; }

@Override
public String toString() {
    return "Person{name='" + name + "', age=" + age + "}";
}</code>

}

public class AtomicReferenceExample { public static void main(String[] args) { AtomicReference atomicPerson = new AtomicReference<>( new Person("Alice", 25) );

    // 获取当前值
    System.out.println("Current: " + atomicPerson.get());

    // 原子更新：将引用改为 Bob
    Person oldPerson = atomicPerson.get();
    boolean success = atomicPerson.compareAndSet(oldPerson, new Person("Bob", 30));
    if (success) {
        System.out.println("Update succeeded");
    } else {
        System.out.println("Update failed - value changed by another thread");
    }

    System.out.println("New value: " + atomicPerson.get());
}

}

在多线程环境中使用 AtomicReference

AtomicReference 特别适合多个线程需要安全地更新共享对象引用的场景。比如状态对象、配置对象或缓存实例的切换。

示例：线程安全的状态切换

AtomicReference<String> status = new AtomicReference<>("INIT");
<p>Runnable worker = () -> {
for (int i = 0; i < 1000; i++) {
String current;
do {
current = status.get();
} while (!status.compareAndSet(current, "WORKING"));</p><pre class="brush:php;toolbar:false"><code>    // 模拟工作
    try { Thread.sleep(1); } catch (InterruptedException e) {}

    // 恢复状态
    status.set("DONE");
}</code>

};

// 启动多个线程竞争修改状态 Thread t1 = new Thread(worker); Thread t2 = new Thread(worker); t1.start(); t2.start();

try { t1.join(); t2.join(); } catch (InterruptedException e) {}

System.out.println("Final status: " + status.get());