C++ Atomic 库 - Fetch Add
描述
它将非原子值添加到原子对象并获得原子的先前值。
声明
以下是 std::atomic_fetch_add 的声明。
template< class Integral > Integral atomic_fetch_add( std::atomic<Integral>* obj, Integral arg );
C++11
template< class Integral > Integral atomic_fetch_add( volatile std::atomic<Integral>* obj, Integral arg );
以下是 std::atomic_fetch_add_explicit 的声明。
template< class T >
T* atomic_fetch_add_explicit( volatile std::atomic<T*>* obj, std::ptrdiff_t arg,
std::memory_order order );
C++11
template< class T >
T* atomic_fetch_add_explicit( std::atomic<T*>* obj, std::ptrdiff_t arg,
std::memory_order order );
参数
obj − 它用于指向要修改的原子对象的指针。
desr − 它用于将值存储在原子对象中。
order − 它用于同步此操作的内存排序。
返回值
它以 *obj 的修改顺序返回此函数效果之前的值。
异常
No-noexcept − 这个成员函数从不抛出异常。
示例
在下面的 std::atomic_fetch_add_explicit 示例中。
#include <string>
#include <thread>
#include <vector>
#include <iostream>
#include <atomic>
#include <chrono>
const int N = 10;
std::atomic<int> cnt = ATOMIC_VAR_INIT(N);
std::vector<int> data;
void reader(int id) {
for(;;) {
while(std::atomic_fetch_sub(&cnt, 1) <= 0)
std::atomic_fetch_add(&cnt, 1);
if(!data.empty())
std::cout << ( "reader " + std::to_string(id)
+ " sees " + std::to_string(*data.rbegin()) + '\n');
if(data.size() == 100)
break;
std::atomic_fetch_add(&cnt, 1);
std::this_thread::sleep_for(std::chrono::milliseconds(1));
}
}
void writer() {
for(int n = 0; n < 100; ++n) {
while(std::atomic_fetch_sub(&cnt, N+1) != N)
std::atomic_fetch_add(&cnt, N+1);
data.push_back(n);
std::cout << "writer pushed back " << n << '\n';
std::atomic_fetch_add(&cnt, N+1);
std::this_thread::sleep_for(std::chrono::milliseconds(1));
}
}
int main() {
std::vector<std::thread> v;
for (int n = 0; n < N; ++n) {
v.emplace_back(reader, n);
}
v.emplace_back(writer);
for (auto& t : v) {
t.join();
}
}
输出应该是这样的 −
writer pushed back 0 reader 8 sees 0 reader 3 sees 0 reader 1 sees 0 ............... reader 2 sees 99 reader 6 sees 99 reader 1 sees 99
