如何在Java中使用AtomicLong处理高并发计数-java教程-PHP中文网

如何在Java中使用AtomicLong处理高并发计数

P粉602998670

发布： 2025-10-21 22:13:01

原创

499人浏览过

使用AtomicLong可解决高并发下计数器线程安全问题，它通过CAS机制保证原子性，示例中100个线程各递增1000次，最终结果正确为100000。

如何在java中使用atomiclong处理高并发计数

在高并发场景下，多个线程同时修改同一个计数器时，使用普通的int或long变量容易出现线程安全问题。Java 提供了 AtomicLong 类来解决这个问题，它通过底层的 CAS（Compare-And-Swap）机制保证操作的原子性，无需使用 synchronized 锁就能实现高效、线程安全的计数。

AtomicLong 的基本用法

AtomicLong 位于 java.util.concurrent.atomic 包中，封装了一个 long 类型的值，并提供了一系列原子操作方法。

常用方法包括：

get()：获取当前值
set(long value)：设置新值
incrementAndGet()：自增并返回新值（等价于 ++i）
decrementAndGet()：自减并返回新值
addAndGet(long delta)：增加指定值并返回结果
compareAndSet(expectedValue, newValue)：如果当前值等于预期值，则更新为新值

示例代码：

import java.util.concurrent.atomic.AtomicLong;

public class Counter {
    private static AtomicLong count = new AtomicLong(0);

    public static void increment() {
        count.incrementAndGet();
    }

    public static long getCount() {
        return count.get();
    }
}

登录后复制

在多线程环境中使用 AtomicLong

下面是一个模拟高并发计数的测试场景，多个线程同时对计数器进行递增操作。

立即学习“Java免费学习笔记（深入）”；

美图设计室

5分钟在线高效完成平面设计，AI帮你做设计

查看详情

public class AtomicLongDemo {
    private static AtomicLong counter = new AtomicLong(0);

    public static void main(String[] args) throws InterruptedException {
        Thread[] threads = new Thread[100];
        
        for (int i = 0; i < threads.length; i++) {
            threads[i] = new Thread(() -> {
                for (int j = 0; j < 1000; j++) {
                    counter.incrementAndGet();
                }
            });
            threads[i].start();
        }

        for (Thread thread : threads) {
            thread.join();
        }

        System.out.println("最终计数值: " + counter.get()); // 预期输出: 100000
    }
}

登录后复制

在这个例子中，即使有 100 个线程各自执行 1000 次递增，最终结果也能准确达到 100000，不会因为竞争而丢失更新。