导读:本期聚焦于小伙伴创作的《如何在多线程环境下安全累加计数器(不加锁的 atomic)》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《如何在多线程环境下安全累加计数器(不加锁的 atomic)》有用,将其分享出去将是对创作者最好的鼓励。

在多线程编程场景中,多个线程同时修改同一个共享计数器是常见需求,传统的synchronized加锁方案虽然能保证线程安全,但会带来上下文切换、阻塞等待等性能开销。而atomic原子类基于硬件层面的CAS(Compare And Swap)机制实现,可以在不加锁的情况下保证计数操作的原子性,是更高效的解决方案。

如何在多线程环境下安全累加计数器(不加锁的 atomic)

atomic的核心原理

atomic类的操作依赖CPU提供的原子指令,以Java中的AtomicInteger为例,它的累加操作并不是简单的读取-修改-写入三步,而是通过CAS机制完成:先读取当前值,计算目标值,然后比较当前值是否和之前读取的一致,如果一致就把目标值写入,不一致就重试整个流程,直到成功为止。整个过程不需要阻塞线程,也不会出现数据竞争问题。

加锁方案与atomic方案对比

我们可以通过一个简单的对比来看两种方案的区别:

方案类型线程安全保证方式性能表现适用场景
synchronized加锁互斥锁,同一时间只有一个线程能操作计数器有锁竞争时性能较低操作逻辑复杂、需要多步原子操作的场景
atomic原子类CAS硬件原子指令,无锁重试无锁竞争时性能更高简单的单变量原子操作场景

代码示例:使用atomic实现安全计数器

以下是Java中使用AtomicInteger实现多线程安全累加的示例:

import java.util.concurrent.atomic.AtomicInteger;

public class AtomicCounter {
    // 初始化原子计数器,初始值为0
    private static final AtomicInteger counter = new AtomicInteger(0);

    // 计数器累加方法,每次加1
    public static void increment() {
        counter.incrementAndGet();
    }

    // 获取当前计数器值
    public static int getCount() {
        return counter.get();
    }

    public static void main(String[] args) throws InterruptedException {
        // 创建10个线程,每个线程累加1000次
        Thread[] threads = new Thread[10];
        for (int i = 0; i < 10; i++) {
            threads[i] = new Thread(() -> {
                for (int j = 0; j < 1000; j++) {
                    increment();
                }
            });
        }

        // 启动所有线程
        for (Thread thread : threads) {
            thread.start();
        }

        // 等待所有线程执行完成
        for (Thread thread : threads) {
            thread.join();
        }

        // 输出最终计数器结果,预期为10000
        System.out.println("最终计数器值:" + getCount());
    }
}

运行上述代码,最终输出的结果一定是10000,不会出现少加的情况,说明AtomicInteger确实保证了累加操作的线程安全。

使用atomic的注意事项

  • atomic只保证单个变量的操作是原子的,如果需要多个变量保持原子性,还是需要加锁或者使用AtomicReference封装对象。
  • 高竞争场景下,CAS重试次数过多会导致CPU占用升高,此时可以评估是否需要切换到加锁方案。
  • 不同编程语言的atomic实现略有差异,比如C++的std::atomic<int>、Go的sync/atomic包,核心原理都是CAS,但API使用方式不同,需要根据对应语言的规范使用。

其他语言的atomic计数器示例

以下是Go语言中使用sync/atomic实现计数器的示例:

package main

import (
    "fmt"
    "sync"
    "sync/atomic"
)

func main() {
    var counter int64
    var wg sync.WaitGroup

    // 启动10个协程,每个协程累加1000次
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for j := 0; j < 1000; j++ {
                // 原子累加操作
                atomic.AddInt64(&counter, 1)
            }
        }()
    }

    wg.Wait()
    // 输出最终计数器值,预期为10000
    fmt.Println("最终计数器值:", counter)
}

atomic多线程计数器无锁编程修改时间:2026-07-05 22:24:20

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。