Java中的 AtomicReference getAcquire() 方法及示例

简介

在Java中，AtomicReference是一种线程安全的类型，可以使用原子方法更新其内部值。

getAcquire() 方法是 AtomicReference 的一个成员方法，用于获取当前引用的值。此方法会以 acquire 的模式获取数据，即先同步执行。

方法签名

public final V getAcquire()

示例代码

import java.util.concurrent.atomic.AtomicReference;

public class AtomicReferenceDemo {
    public static void main(String[] args) {
        AtomicReference<String> atomicReference = new AtomicReference<>("Hello World");

        System.out.println("Initial Value: " + atomicReference.get());

        Thread t1 = new Thread(() -> {
            String oldValue = atomicReference.getAndSet("New Value");
            System.out.println("Thread 1 Old Value: " + oldValue);
        });

        Thread t2 = new Thread(() -> {
            String currentValue = atomicReference.getAcquire();
            System.out.println("Thread 2 Current Value: " + currentValue);
        });

        t1.start();
        t2.start();

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

        System.out.println("Final Value: " + atomicReference.get());
    }
}

代码说明

1. 首先我们创建了一个 AtomicReference 类型的对象 atomicReference，并将其初始化为 Hello World。
2. 我们输出了 atomicReference 的初始值。
3. 我们创建了两个线程 t1 和 t2，用于演示线程安全。
   • t1 调用了 getAndSet() 方法，用于设置新的值并获取旧的值。
   • t2 调用了 getAcquire() 方法，用于获取当前的值。
4. 我们启动了线程 t1 和 t2，并使用 join() 方法等待它们执行完毕。
5. 最后，我们输出了 atomicReference 对象的最终值。

运行结果

Initial Value: Hello World
Thread 2 Current Value: Hello World
Thread 1 Old Value: Hello World
Final Value: New Value

可以看到，在使用 getAcquire() 方法获取值时，它会以 acquire 的模式获取数据，即先同步执行。这保证了过时值不会被访问到，同时也保证了线程安全性。