java - 在 AtomicInteger.addAndGet(int) 中使用无限循环

Question

在 Java 的包 java.util.concurrent.atomic AtomicInteger 类中有一个方法 addAndGet(int)

这是

public final int addAndGet(int delta) {
    for (;;) {
        int current = get();
        int next = current + delta;
        if (compareAndSet(current, next))
            return next;
    }
}

这里为什么要无限循环设置一个值？

Answer 1

这是 CAS loop 的经典例子. compare-and-set 是一个具有直接硬件支持的原子操作(通常背后有一些 CPU 指令)。它仅在当前值等于预期值时才自动更新给定变量，如果一切成功则返回 true。通常这个循环只执行一次。然而在争用下(当其他线程尝试更新相同的值时)有可能在通过 get() 读取当前值和通过 compareAndSet 更新它之间另一个线程设法更新它.在这种情况下，将重试整个过程直到成功。

在这里使用无限循环只是一种风格问题。它可以使用普通的 do-while 循环重写:

public final int addAndGet(int delta) {
    int current, next;
    do {
        current = get();
        next = current + delta;
    } while (!compareAndSet(current, next));
    return next;
}