atomic：std::atomic_fetch_min和std::atomic_fetch_min_explicit

引入

在并发编程中，安全地管理共享数据是一项重要任务。C++标准库的<atomic>头文件提供了一系列原子操作，其中std::atomic_fetch_min和std::atomic_fetch_min_explicit用于在多线程环境中可靠地执行原子最小值操作。使用这两个函数，开发者可以安全地更新共享变量的最小值，同时保持线程安全性和数据一致性。这些功能在涉及最大值或最小值追踪的应用场景中尤为重要。本文将详细探讨这两个函数的特性、功能语法、示例代码及适用场景。

特性/函数/功能语法介绍

std::atomic_fetch_min

std::atomic_fetch_min的主要特性包括：

• 原子性：确保在更新最小值时，不会受到其他线程的干扰。
• 简单性：提供易于使用的接口，使得原子最小值操作变得直观。

语法

#include <atomic>

T std::atomic_fetch_min(std::atomic<T>& obj, T arg);

std::atomic_fetch_min_explicit

std::atomic_fetch_min_explicit的主要特性包括：

• 内存序控制：允许开发者指定内存序，以适应多线程操作的不同场景。
• 适用于需要优化的场景：提供更高的灵活性，满足复杂并发需求的应用。

语法

#include <atomic>

T std::atomic_fetch_min_explicit(std::atomic<T>& obj, T arg, std::memory_order order);

参数order可以是：

• memory_order_relaxed：无顺序保证。
• memory_order_acquire：确保之前的所有读取在这个调用之前完成。
• memory_order_release：确保这个调用之后的所有写入在操作完成后执行。
• memory_order_acq_rel：同时保证读取和写入的顺序。
• memory_order_seq_cst：确保处理的全局顺序一致。

完整示例代码

以下示例代码展示了如何使用std::atomic_fetch_min和std::atomic_fetch_min_explicit对共享变量执行原子最小值操作：

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

std::atomic<int> sharedMin{100}; // 初始值为100

void update_min(int value) {
    for (int i = 0; i < 3; ++i) {
        int oldValue = std::atomic_fetch_min(sharedMin, value); // 使用atomic_fetch_min
        std::cout << "Thread " << std::this_thread::get_id() 
                  << " tried to set min from " << oldValue 
                  << " to " << value 
                  << ", resulting in min: " << std::min(oldValue, value) << std::endl;
        std::this_thread::sleep_for(std::chrono::milliseconds(500));
    }
}

void update_min_explicit(int value) {
    for (int i = 0; i < 3; ++i) {
        int oldValue = std::atomic_fetch_min_explicit(sharedMin, value, std::memory_order_seq_cst); // 使用atomic_fetch_min_explicit
        std::cout << "Thread " << std::this_thread::get_id() 
                  << " tried to set min(explicit) from " << oldValue 
                  << " to " << value 
                  << ", resulting in min: " << std::min(oldValue, value) << std::endl;
        std::this_thread::sleep_for(std::chrono::milliseconds(500));
    }
}

int main() {
    std::thread t1(update_min, 50);  // 线程尝试更新最小值为50
    std::thread t2(update_min_explicit, 25); // 线程尝试更新最小值为25

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

    std::cout << "Final minimum value: " << sharedMin.load() << std::endl; // 输出最终的最小值
    return 0;
}

代码解析

在这个示例中，我们通过std::atomic_fetch_min和std::atomic_fetch_min_explicit对共享变量执行原子最小值操作：

1. 创建原子变量：

   • std::atomic<int> sharedMin{100}; 声明一个原子整型变量并初始化为100，用于存储最小值。

2. 更新最小值的线程：

   • 在 update_min 函数中，通过调用 std::atomic_fetch_min(sharedMin, value) 尝试设置新的最小值，并返回旧值，以确保操作的原子性。

3. 更新最小值的线程（显式内存序）：

   • 在 update_min_explicit 函数中，使用 std::atomic_fetch_min_explicit(sharedMin, value, std::memory_order_seq_cst)，同时指定内存序为 memory_order_seq_cst。

4. 主函数：

   • 在 main 函数中，创建两个线程分别调用不同的最小值更新函数，一个线程尝试设置最小值为50，另一个尝试设置为25，等待它们完成后再输出最终值。

5. 最终值显示：

   • 最后输出 sharedMin 的最终值，以展示对该变量的按需更新。

适用场景分析

std::atomic_fetch_min和std::atomic_fetch_min_explicit的应用场景包括：

1. 最小值跟踪：在多线程环境中，实时跟踪最小值，比如实时监控应用中的资源使用情况。

2. 负载均衡：在服务器集群中，跟踪最小负载，以便选择最轻负载的服务器来处理请求。

3. 数据统计：在并发数据处理中，确保统计数据的最小值是实时更新的，对多线程分析工具至关重要。

总结

std::atomic_fetch_min和std::atomic_fetch_min_explicit为C++提供了有效且安全的原子最小值操作，确保多线程环境中的数据一致性和线程安全。通过本文的示例，读者可以了解如何利用这些操作来管理共享状态，并在实际应用中有效提高程序的稳定性和性能。掌握这些原子操作将帮助开发者在复杂的并发环境中构建更高效的解决方案。合理使用这些函数不仅能降低并发编程中的复杂性，还能增强程序的可靠性。