std:: atomic_fetch_add, std:: atomic_fetch_add_explicit
|
헤더에 정의됨
<atomic>
|
||
|
template
<
class
T
>
T atomic_fetch_add
(
std::
atomic
<
T
>
*
obj,
|
(1) | (C++11부터) |
|
template
<
class
T
>
T atomic_fetch_add
(
volatile
std::
atomic
<
T
>
*
obj,
|
(2) | (C++11부터) |
|
template
<
class
T
>
T atomic_fetch_add_explicit
(
std::
atomic
<
T
>
*
obj,
|
(3) | (C++11부터) |
|
template
<
class
T
>
T atomic_fetch_add_explicit
(
volatile
std::
atomic
<
T
>
*
obj,
|
(4) | (C++11부터) |
원자적 덧셈을 수행합니다. arg 값을 obj 가 가리키는 값에 원자적으로 더하고, 이전에 obj 가 보유하던 값을 반환합니다. 이 연산은 다음과 같이 실행된 것처럼 수행됩니다:
만약
std::atomic<T>
에
fetch_add
멤버가 없는 경우 (이 멤버는
정수형
,
부동소수점형
(C++20부터)
및
포인터
타입에 대해서만 제공됨,
bool
제외), 프로그램은 형식에 맞지 않습니다.
목차 |
매개변수
| obj | - | 수정할 atomic 객체에 대한 포인터 |
| arg | - | atomic 객체에 저장된 값에 더할 값 |
| order | - | 메모리 동기화 순서 |
반환값
이 함수의 효과가 적용되기 직전의 값으로, modification order 에서 * obj 의 값입니다.
예제
단일 작성자/다중 판독자 잠금은
std::atomic_fetch_add
로 구현할 수 있습니다. 이 단순화된 구현이 lockout-free가 아님에 유의하십시오.
#include <atomic> #include <chrono> #include <iostream> #include <string> #include <thread> #include <vector> using namespace std::chrono_literals; // meaning of cnt: // 5: readers and writer are in race. There are no active readers or writers. // 4...0: there are 1...5 active readers, The writer is blocked. // -1: writer won the race and readers are blocked. const int N = 5; // four concurrent readers are allowed std::atomic<int> cnt(N); std::vector<int> data; void reader(int id) { for (;;) { // lock while (std::atomic_fetch_sub(&cnt, 1) <= 0) std::atomic_fetch_add(&cnt, 1); // read if (!data.empty()) std::cout << ("reader " + std::to_string(id) + " sees " + std::to_string(*data.rbegin()) + '\n'); if (data.size() == 25) break; // unlock std::atomic_fetch_add(&cnt, 1); // pause std::this_thread::sleep_for(1ms); } } void writer() { for (int n = 0; n < 25; ++n) { // lock while (std::atomic_fetch_sub(&cnt, N + 1) != N) std::atomic_fetch_add(&cnt, N + 1); // write data.push_back(n); std::cout << "writer pushed back " << n << '\n'; // unlock std::atomic_fetch_add(&cnt, N + 1); // pause std::this_thread::sleep_for(1ms); } } 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 2 sees 0 reader 3 sees 0 reader 1 sees 0 <...> reader 2 sees 24 reader 4 sees 24 reader 1 sees 24
결함 보고서
다음 동작 변경 결함 보고서는 이전에 게시된 C++ 표준에 소급 적용되었습니다.
| DR | 적용 대상 | 게시된 동작 | 올바른 동작 |
|---|---|---|---|
| P0558R1 | C++11 |
정확한 타입 일치가 요구되었음
T
가 여러 인수에서 추론되었기 때문
|
T
는 오직
obj 에서만 추론됨 |
참고 항목
|
원자 객체에 저장된 값에 인자를 더하고 이전에 보유한 값을 획득합니다
(
std::atomic<T>
의
public member function)
|
|
|
(C++11)
(C++11)
|
원자 객체에서 비원자 값을 빼고 원자의 이전 값을 획득합니다
(function template) |
|
C documentation
for
atomic_fetch_add
,
atomic_fetch_add_explicit
|
|