C++ 11中与std::atomic的同步

基础概念

std::atomic 是 C++11 引入的一个模板类，用于实现原子操作。原子操作是指不可分割的操作，即在执行过程中不会被其他线程中断。这在多线程编程中非常重要，因为它可以避免数据竞争（data race）和不一致的状态。

类型

std::atomic 支持多种基本数据类型的原子操作，包括：

std::atomic_flag
std::atomic<bool>
std::atomic<char>
std::atomic<short>
std::atomic<int>
std::atomic<long>
std::atomic<long long>
std::atomic<unsigned char>
std::atomic<unsigned short>
std::atomic<unsigned int>
std::atomic<unsigned long>
std::atomic<unsigned long long>
std::atomic<float>
std::atomic<double>

此外，还可以通过特化 std::atomic 来支持自定义类型的原子操作。

应用场景

计数器：在多线程环境中，使用 std::atomic 实现计数器，确保计数的准确性。
标志位：用于多线程间的状态同步，例如，一个线程设置一个标志位，另一个线程检查该标志位。
共享资源访问：在多线程环境中，使用 std::atomic 确保对共享资源的访问是原子的，避免数据竞争。

示例代码

以下是一个简单的示例，展示如何使用 std::atomic 实现一个线程安全的计数器：

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

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

void increment() {
    for (int i = 0; i < 100000; ++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 << "Counter: " << counter.load(std::memory_order_relaxed) << std::endl;
    return 0;
}

在这个示例中，两个线程并发地增加 counter 的值，由于使用了 std::atomic，最终的计数结果是准确的。

遇到的问题及解决方法

问题：为什么使用 `std::atomic` 还会出现数据不一致的情况？

原因：虽然 std::atomic 提供了原子操作，但如果程序逻辑中存在复合操作（例如，读取-修改-写入），而这些复合操作本身不是原子的，仍然可能导致数据不一致。

解决方法：确保复合操作也是原子的，或者使用锁机制来保护这些复合操作。例如，可以使用 std::mutex 或 std::shared_mutex 来保护复合操作。

#include <iostream>
#include <thread>
#include <atomic>
#include <mutex>

std::atomic<int> counter(0);
std::mutex mtx;

void increment() {
    for (int i = 0; i < 100000; ++i) {
        std::lock_guard<std::mutex> lock(mtx);
        counter++;
    }
}

int main() {
    std::thread t1(increment);
    std::thread t2(increment);

    t1.join();
    t2.join();

    std::cout << "Counter: " << counter.load() << std::endl;
    return 0;
}

在这个示例中，使用 std::mutex 保护了对 counter 的复合操作，确保了数据的一致性。