C语言- 原子操作

基本概念

在C语言（尤其是C11标准之后）中，原子操作提供了一种机制，使得程序员可以在并发环境中，不使用互斥或其他同步原语，而直接对数据进行操作，同时确保数据的完整性和一致性。

原子变量和原子操作的核心思想是：无论什么时候，只有一个线程能够看到变量的修改操作。这种修改要么完全发生，要么完全不发生，没有中间状态。因此，这可以避免诸如“脏读”这样的并发问题。

原子类型

C11引入了头文件，其中定义了各种原子类型，例如：

• atomic_int
• atomic_long
• atomic_bool
  等等。

原子操作

对这些原子类型的变量进行操作时，可以使用以下原子操作函数：

• atomic_store：原子存储值。
• atomic_load：原子读取值。
• atomic_fetch_add：原子增加。
• atomic_fetch_sub：原子减少。
• atomic_exchange：原子交换值。
• atomic_compare_exchange_strong和atomic_compare_exchange_weak：原子比较和交换。

这些操作确保在并发环境中，对原子变量的读取和修改是安全的。

内存顺序

为了实现高效的并发操作，现代硬件提供了各种各样的内存访问和指令执行的乱序（out-of-order）技术。这可能导致在不同的核或线程上观察到不同的指令和内存访问顺序。为了管理这种复杂性，提供了不同的内存顺序选项：

• memory_order_relaxed：放松的内存顺序，没有同步或顺序需求。
• memory_order_acquire：在相关的原子操作前不会有内存重排序。
• memory_order_release：在相关的原子操作后不会有内存重排序。
• memory_order_acq_rel：同时具有acquire和release语义。
• memory_order_seq_cst：为所有原子操作提供完整的序列一致性。

选择合适的内存顺序对于确保并发程序的正确性和性能至关重要。

总之，原子操作为C程序员提供了一种在高度并发的环境中对数据进行高效、安全操作的方法，无需使用复杂的同步原语。然而，正确和高效地使用原子操作需要对内存模型、内存顺序和硬件的实际行为有深入的了解。

---

原子类型

atomic_int

atomic_int 是 C11 和 C++11 标准库中提供的原子类型。它是专门为 int 类型设计的原子版本，用于在多线程环境中确保对 int 类型的变量进行的操作是原子的，从而避免数据竞争和其他相关的并发问题。

1. 定义：

在 C11 中，atomic_int 是一个原子整数类型。在 C++11 中，它被定义为 std::atomic。

2. 特性：

• 原子性: 对 atomic_int 的操作（如递增、递减、存储和加载）是原子的，这意味着当一个线程对其进行操作时，其他线程不能同时对其进行操作。
• 内存序: atomic_int 操作通常与特定的内存序关联，这些内存序定义了操作的可见性和顺序。例如，一个线程在某个 atomic_int 上执行的写操作何时对另一个线程可见。
• 无锁: atomic_int 的实现通常是无锁的，尽管具体实现可能取决于平台和硬件支持。无锁实现通常比使用互斥锁或其他同步原语更高效。

3. 常见操作：

以下是可以在 atomic_int 上执行的一些原子操作：

• load: 获取变量的当前值。
• store: 设置变量的值。
• fetch_add: 增加变量的值并返回旧值。
• fetch_sub: 减少变量的值并返回旧值。
• exchange: 设置变量的值并返回旧值。
• compare_exchange_strong 和 compare_exchange_weak: 条件性地设置变量的值。

4. 示例：

#include 
#include 
#include 

atomic_int counter = 0;

void* increment(void* arg) {
   
    for (int i = 0; i < 1000; ++i) {
   
        atomic_fetch_add(&counter, 1);
    }
    return NULL;
}

int main() {
   
    pthread_t threads[10];
    for (int i = 0; i < 10; i++) {
   
        pthread_create(&threads[i], NULL, increment, NULL);
    }
    for (int i = 0; i < 10; i++) {
   
        pthread_join(threads[i], NULL);
    }
    printf("Counter: %d\n", atomic_load(&counter));
    return 0;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

在上述示例中，我们使用 atomic_int 作为计数器，启动了 10 个线程，每个线程都增加计数器 1000 次。使用 atomic_int 确保在并发环境中对计数器的所有操作都是原子的。

总之，atomic_int 是一种线程安全的整数类型，它提供了一系列原子操作，使得多个线程可以同时而安全地访问和修改其值，无需担心数据竞争或其他并发问题。

atomic_bool

atomic_bool 是 C11 和 C++11 标准库中提供的原子类型，专为布尔类型设计。这意味着在多线程环境下，对一个 atomic_bool 类型的变量进行的操作是原子性的，这在确保线程安全性和避免数据竞争时非常有价值。

1. 定义：

在 C11 中，atomic_bool 是一个原子布尔类型。在 C++11 中，它被定义为 std::atomic。

2. 特性：

• 原子性: 对 atomic_bool 的操作（如存储、加载、逻辑运算）是原子的。这意味着在任何给定时刻，只有一个线程可以对它进行操作，而其他线程不能看到该操作的中间状态。

• 内存序: atomic_bool 提供了与特定的内存序关联的操作。这些内存序定义了操作的可见性和顺序，例如一个线程执行的写操作何时对另一个线程可见。

• 无锁: 在大多数平台上，atomic_bool 的实现是无锁的。具体的实现可能会根据平台和硬件支持而变化，但无锁实现通常比使用互斥锁或其他同步原语更高效。

3. 常见操作：
以下是可以在 atomic_bool 上执行的一些原子操作：

• load: 获取变量的当前值。
• store: 设置变量的值。
• exchange: 设置变量的值并返回旧值。
• compare_exchange_strong 和 compare_exchange_weak: 条件性地设置变量的值。

4. 示例：

#include 
#include 
#include 

atomic_bool flag = ATOMIC_VAR_INIT(false);

void* set_flag(void* arg) {
   
    atomic_store(&flag, true);
    return NULL;
}

int main() {
   
    pthread_t thread;
    pthread_create(&thread, NULL, set_flag, NULL);
    pthread_join(thread, NULL);
    
    bool is_set = atomic_load(&flag);
    printf("Flag is %s\n", is_set ? "set" : "not set");
    return 0;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

在上述示例中，我们使用 atomic_bool 作为一个标志，并启动了一个线程来设置这个标志。使用 atomic_bool 确保了在并发环境中对标志的所有操作都是原子的。

总之，atomic_bool 提供了一个线程安全的方式来操作布尔变量，在并发编程中非常有用，特别是当需要确保对变量的操作是原子的时候。

---

原子操作

atomic_store

atomic_store 是C11标准中提供的一组原子操作函数，用于存储一个值到一个原子变量，确保这个操作是原子的，即在操作期间不会被其他线程中断。这种保证有助于防止在并发环境中出现数据竞争和不一致状态。

1. 声明：

原型为：

void atomic_store(volatile A *obj, C desired);
1

其中，

• A 必须是原子类型。
• obj 是要进行操作的原子对象的指针。
• desired 是要存储到原子对象的值。

2. 描述：

atomic_store 将 desired 的值原子地存储到 *obj