c++ std::atomic原子操作怎么使用_c++原子类型与多线程同步机制

冰火之心

发布时间：2025-11-23 18:18:06

283人浏览过

来源于php中文网

原创

原子操作是不可分割的操作，能避免数据竞争。std::atomic 提供原子类型的读写操作，如 load、store、fetch_add 和 compare_exchange_weak，确保多线程下共享变量的安全访问，常用于计数器、标志位等场景，相比互斥锁更高效，并通过内存序控制同步强度，其中默认的 std::memory_order_seq_cst 提供最强顺序保证。

c++ std::atomic原子操作怎么使用_c++原子类型与多线程同步机制

在C++多线程编程中，std::atomic 提供了一种无需互斥锁（mutex）即可安全访问共享数据的方式。它通过原子操作保证对变量的读取、修改、写入是不可分割的，避免了数据竞争（data race），从而实现高效的线程同步。

什么是原子操作？

原子操作是指一个操作在执行过程中不会被其他线程中断。比如对一个计数器进行自增，在非原子情况下可能被多个线程同时读取、修改，导致结果错误。而使用 std::atomic 后，这个操作就是“一步完成”的，确保线程安全。

基本用法：定义和初始化原子变量

你可以将整型、指针等类型包装成原子类型：

#include <atomic>
#include <iostream>

std::atomic<int> counter(0);  // 初始化为0
std::atomic<bool> ready(false);
std::atomic<int*> ptr(nullptr);

支持的原子类型包括：int、long、bool、指针等基础类型。不能用于复杂对象（如 std::string），此时应使用互斥量。

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

常用原子操作函数

std::atomic 提供了多种操作方式，常用的有：

load()：原子地读取当前值
store(value)：原子地写入新值
exchange(value)：设置新值，并返回旧值
compare_exchange_weak(expected, desired)：比较并交换（CAS），是实现无锁结构的基础
fetch_add() / fetch_sub()：原子加减，返回原值

示例代码：

#include <thread>
#include <vector>
#include <atomic>
#include <iostream>

std::atomic<int> count(0);

void increment() {
    for (int i = 0; i < 1000; ++i) {
        count.fetch_add(1, std::memory_order_relaxed);
    }
}

int main() {
    std::vector<std::thread> threads;
    for (int i = 0; i < 10; ++i) {
        threads.emplace_back(increment);
    }

    for (auto& t : threads) {
        t.join();
    }

    std::cout << "Final count: " << count.load() << "\n";
    return 0;
}

上面的例子中，10个线程各对原子变量增加1000次，最终结果一定是10000，不会出现数据竞争。

Winston AI

强大的AI内容检测解决方案

下载

内存序（Memory Order）的选择

std::atomic 的操作可以指定内存顺序，控制编译器和CPU的重排序行为。常见选项包括：

std::memory_order_relaxed：只保证原子性，不保证顺序，性能最好
std::memory_order_acquire：用于读操作，确保之后的读写不会被重排到它前面
std::memory_order_release：用于写操作，确保之前的读写不会被重排到它后面
std::memory_order_acq_rel：acquire + release，常用于CAS
std::memory_order_seq_cst：默认选项，最严格的顺序一致性，开销最大

大多数场景下使用默认的 std::memory_order_seq_cst 就足够了。只有在追求极致性能且理解内存模型时才需要调整。

compare-and-swap 的典型用法

CAS 是实现无锁算法的核心。下面是一个使用 compare_exchange_weak 安全更新值的例子：

std::atomic<int> val(100);

int expected = 100;
if (val.compare_exchange_weak(expected, 200)) {
    std::cout << "Updated from " << expected << " to 200\n";
} else {
    std::cout << "Failed: current value is " << val.load() << ", expected was " << expected << "\n";
}

如果 val 当前等于 expected，则设为 200 并返回 true；否则将 expected 更新为当前值并返回 false。