C++如何使用std::atomic实现无锁编程_C++并发编程与原子操作实践

std::atomic 提供原子操作以避免数据竞争，相比互斥锁性能更高，适用于高并发场景。通过 memory_order 可控制内存顺序，如 relaxed 用于独立操作，acquire/release 用于同步，seq_cst 保证顺序一致性。compare_exchange_weak 支持无锁数据结构如栈的实现，但需注意 ABA 问题和内存回收。合理使用可提升并发效率，但需谨慎处理复杂性。

在C++并发编程中，std::atomic 是实现无锁（lock-free）操作的核心工具。它保证对共享数据的读写是原子的，避免多个线程同时访问导致的数据竞争和未定义行为。相比互斥锁（mutex），原子操作通常性能更高，尤其适用于高并发、低争用的场景。

理解 std::atomic 的基本用法

std::atomic 模板类可以包装一个基础类型（如 int、bool、指针等），使其操作具有原子性。最常见的是 std::atomic 或 std::atomic。

例如，实现一个线程安全的计数器：

#include 
#include 
#include 
std::atomic counter{0};
立即学习“C++免费学习笔记（深入）”；
void increment() {
for (int i = 0; i < 1000; ++i) {
counter.fetch_add(1, std::memory_order_relaxed);
}
}
int main() {
std::thread t1(increment);
std::thread t2(increment);
t1.join();
t2.join();

std::cout zuojiankuohaophpcnzuojiankuohaophpcn "Counter: " zuojiankuohaophpcnzuojiankuohaophpcn counter.load() zuojiankuohaophpcnzuojiankuohaophpcn "\n";
return 0;
}
这里使用 fetch_add 原子地增加计数器值，确保不会出现竞态条件。
内存顺序（Memory Order）的选择
原子操作的性能和语义受内存顺序影响。C++ 提供了多种 std::memory_order 枚举值：

							

								
								

									知了追踪
									
AI智能信息助手，智能追踪你的兴趣资讯
								
								下载 
							
						


memory_order_relaxed：仅保证原子性，不提供同步或顺序约束，适合计数器等独立操作。

memory_order_acquire：用于读操作，保证之后的读写不会被重排到该操作之前。

memory_order_release：用于写操作，保证之前的读写不会被重排到该操作之后。

memory_order_acq_rel：结合 acquire 和 release，常用于 compare-exchange 操作。

memory_order_seq_cst：默认顺序，提供最严格的顺序一致性，但开销最大。

例如，在实现自旋锁或标志位通知时，使用 acquire/release 可以避免不必要的全局同步开销：
std::atomic ready{false};
int data = 0;
// 线程1：生产数据
void producer() {
data = 42;
ready.store(true, std::memory_order_release);
}
// 线程2：消费数据
void consumer() {
while (!ready.load(std::memory_order_acquire)) {
// 自旋等待
}
std::cout << "Data: " << data << "\n";
}
这种模式确保了 data 的写入在 ready 变为 true 之前完成，且消费者能看到正确的 data 值。
使用 compare_exchange_weak 实现无锁结构
无锁编程的核心是利用 compare_exchange_weak 或 compare_exchange_strong 实现原子更新。这个操作是“比较并交换”（CAS），常用于构建无锁队列、栈等数据结构。
下面是一个简单的无锁栈实现片段：
template
class LockFreeStack {
private:
    struct Node {
        T data;
        Node* next;
        Node(T const& d) : data(d), next(nullptr) {}
    };
    std::atomic head{nullptr};
public:
void push(T const& data) {
Node* new_node = new Node(data);
new_node->next = head.load();
while (!head.compare_exchange_weak(new_node->next, new_node)) {
// 如果 head 被其他线程修改，new_node->next 会被更新为当前 head
// 循环继续尝试
}
}
bool pop(T& result) {
    Node* old_head = head.load();
    while (old_head && !head.compare_exchange_weak(old_head, old_head-youjiankuohaophpcnnext)) {
        // 更新 old_head 为当前 head，继续尝试
    }
    if (old_head) {
        result = old_head-youjiankuohaophpcndata;
        delete old_head;
        return true;
    }
    return false;
}
};
注意：真实项目中需考虑 ABA 问题和内存回收（如使用 hazard pointer 或 RCU）。
基本上就这些。合理使用 std::atomic 能写出高效、低延迟的并发代码，但要小心内存顺序和复杂逻辑带来的隐患。无锁编程虽强，但也容易出错，建议在关键路径或性能敏感场景下谨慎使用。