Cpp-standard-library-cpp-atomic-fetch-add

C ++アトミックライブラリ-フェッチ追加

説明

アトミックオブジェクトに非アトミック値を追加し、アトミックの以前の値を取得します。

宣言

以下は、std

atomic_fetch_addの宣言です。

template< class Integral >
Integral atomic_fetch_add( std::atomic<Integral>* obj, Integral arg );

Copy

C 11

template< class Integral >
Integral atomic_fetch_add( volatile std::atomic<Integral>* obj, Integral arg );

Copy

以下は、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 );

Copy

C 11

template< class T >
T* atomic_fetch_add_explicit( std::atomic<T*>* obj, std::ptrdiff_t arg,
                              std::memory_order order );

Copy

パラメーター

• obj -変更するアトミックオブジェクトへのポインタで使用されます。
• desr -値をアトミックオブジェクトに格納するために使用されます。
• order -この操作のメモリ順序を同期するために使用されます。

戻り値

この関数の効果の直前の値を* objの変更順で返します。

例外

*No-noexcept* -このメンバー関数は例外をスローしません。

Copy

例

以下の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();
   }
}

Copy

出力は次のようになります-

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

Copy