Java 中怎么在多线程环境下使用 AtomicInteger 的 compareAndSet 实现并发计数与乐观重试-java教程-PHP中文网

AtomicInteger.compareAndSet是基于CAS指令的无锁原子操作，语义为：仅当当前值等于预期值时才更新为新值并返回true，否则不修改并返回false；它支撑乐观重试机制，典型用法是循环调用get()与compareAndSet()实现线程安全自增等复合操作。

java 中怎么在多线程环境下使用 atomicinteger 的 compareandset 实现并发计数与乐观重试

在多线程环境下，AtomicInteger.compareAndSet 是实现无锁（lock-free）并发计数与乐观重试的核心手段。它基于 CPU 的 CAS（Compare-And-Swap）指令，原子地判断当前值是否等于预期值，是则更新为新值，否则失败并返回 false —— 这正是“乐观”策略的基础：先假设能成功，失败后再重试。

理解 compareAndSet 的语义和典型用法

compareAndSet(expected, newValue) 会检查当前整数值是否等于 expected；只有相等才设为 newValue，并返回 true；否则不修改、直接返回 false。它不阻塞线程，也不依赖 synchronized 或 Lock，适合高竞争但更新逻辑简单的场景（如计数器自增）。

常见误用是把 get() 结果直接当 expected 传入，却忽略中间可能已被其他线程修改。正确做法是循环重试，每次重新读取当前值作为比较基准：

调用 get() 获取当前值 current
计算目标值（如 next = current + 1）
用 compareAndSet(current, next) 尝试更新
若返回 false，说明期间有其他线程抢先改了值，回到第一步重试

实现线程安全的自增计数器（乐观重试模式）

下面是一个标准的、基于 CAS 循环的线程安全自增方法：

public int incrementAndGet(AtomicInteger counter) {
    int current;
    int next;
    do {
        current = counter.get();
        next = current + 1;
    } while (!counter.compareAndSet(current, next));
    return next;
}

这个循环就是“乐观重试”的体现：不加锁、不挂起，靠反复尝试直到成功。JDK 中 AtomicInteger.incrementAndGet() 内部正是这样实现的（底层还做了少许优化，比如避免重复调用 get()）。

注意：该循环在低竞争下极高效；但在极高竞争下可能引发大量 CAS 失败和空转（busy-spin），此时可考虑 LongAdder 等分段累加器来降低热点。

Java调试

通过 JDWP 实现 Java 远程调试：连接远程 JVM、设置断点、单步执行代码、查看变量值、获取调用栈。适用于需要调试远程 Java 应用、排查运行时状态、追踪代码执行流程的场景。术语注解 JDWP：Java Debug Wire Protocol，Java 调试有线协议（Java 远程调试底层通信协议） remote JVM：远程 Java 虚拟机 step through code：代码单步调试（步入 / 步过 / 步出调试） inspect variables：变量查看 / 变量检视 stac

下载

扩展：带业务条件的 CAS 更新（例如仅当值为偶数时加 1）

利用 compareAndSet 的条件性，可以实现更复杂的原子逻辑。比如只在当前计数值为偶数时才执行自增：

public boolean incrementIfEven(AtomicInteger counter) {
    int current;
    int next;
    do {
        current = counter.get();
        if (current % 2 != 0) {
            return false; // 不满足条件，放弃
        }
        next = current + 1;
    } while (!counter.compareAndSet(current, next));
    return true;
}

这种写法保持了原子性和线程安全性，且无需外部同步。关键在于所有判断都基于同一时刻的 current 值，更新也仅在条件成立且未被干扰时发生。