C++ Atomic::fetch_add() 函数



C++ 的std::atomic::fetch_add()函数用于将指定的值添加到原子对象,并返回对象在添加之前保存的值。此函数可以防止竞争条件,确保多个线程可以安全地更新共享变量,而不会导致数据损坏。

语法

以下是 std::atomic::fetch_add() 函数的语法。

T fetch_add (T val, memory_order sync = memory_order_seq_cst) volatile noexcept;
T fetch_add (T val, memory_order sync = memory_order_seq_cst) noexcept;
or
T fetch_add (ptrdiff_t val, memory_order sync = memory_order_seq_cst) volatile noexcept;
T fetch_add (ptrdiff_t val, memory_order sync = memory_order_seq_cst) noexcept;

参数

  • val - 表示要添加的值。
  • sync - 表示操作的同步模式。

返回值

此函数返回调用前的包含值。

异常

此成员函数从不抛出异常。

示例

在以下示例中,我们将考虑 fetch_add() 函数的基本用法。

#include <iostream>
#include <atomic>
int main()
{
    std::atomic<int> x(11);
    int y = x.fetch_add(2);
    std::cout << "Old value: " << y << std::endl;
    std::cout << "New value: " << x << std::endl;
    return 0;
}

输出

以上代码的输出如下:

Old value: 11
New value: 13

示例

考虑以下示例,我们将在此示例中在循环中使用 fetch_add() 函数。

#include <iostream>
#include <atomic>
#include <thread>
#include <vector>
int main()
{
    std::atomic<int> a(1);
    std::vector<std::thread> b;
    for (int x = 0; x < 3; ++x) {
        b.emplace_back([&a]() {
            for (int y = 0; y < 10; ++y) {
                a.fetch_add(1);
            }
        });
    }
    for (auto& thread : b) {
        thread.join();
    }
    std::cout << "Result : " << a << std::endl;
    return 0;
}

输出

以下是以上代码的输出:

Result : 31

示例

让我们来看以下示例,我们将在此示例中添加负值。

#include <iostream>
#include <atomic>
int main()
{
    std::atomic<int> x(12);
    int a = x.fetch_add(-6);
    std::cout << "Result after fetch_add: " << a << std::endl;
    std::cout << "Atomic variable after fetch_add: " << x << std::endl;
    return 0;
}

输出

如果我们运行以上代码,它将生成以下输出:

Result after fetch_add: 12
Atomic variable after fetch_add: 6
atomic.htm
广告