std:: atomic_fetch_add, std:: atomic_fetch_add_explicit
|
Défini dans l'en-tête
<atomic>
|
||
|
template
<
class
T
>
T atomic_fetch_add
(
std::
atomic
<
T
>
*
obj,
|
(1) | (depuis C++11) |
|
template
<
class
T
>
T atomic_fetch_add
(
volatile
std::
atomic
<
T
>
*
obj,
|
(2) | (depuis C++11) |
|
template
<
class
T
>
T atomic_fetch_add_explicit
(
std::
atomic
<
T
>
*
obj,
|
(3) | (depuis C++11) |
|
template
<
class
T
>
T atomic_fetch_add_explicit
(
volatile
std::
atomic
<
T
>
*
obj,
|
(4) | (depuis C++11) |
Effectue une addition atomique. Ajoute atomiquement arg à la valeur pointée par obj et retourne la valeur obj détenue précédemment. L'opération est effectuée comme si l'exécution suivante avait lieu :
Si
std::atomic<T>
ne possède pas de membre
fetch_add
(ce membre est uniquement fourni pour les types
intégraux
,
flottants
(depuis C++20)
et
pointeurs
, à l'exception de
bool
), le programme est mal formé.
Table des matières |
Paramètres
| obj | - | pointeur vers l'objet atomique à modifier |
| arg | - | la valeur à ajouter à la valeur stockée dans l'objet atomique |
| order | - | l'ordonnancement de synchronisation de la mémoire |
Valeur de retour
La valeur précédant immédiatement les effets de cette fonction dans l' ordre de modification de * obj .
Exemple
Un verrou à un écrivain/multiple lecteurs peut être réalisé avec
std::atomic_fetch_add
. Notez que cette implémentation simpliste n'est pas sans blocage.
#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(); }
Sortie :
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
Rapports de défauts
Les rapports de défauts modifiant le comportement suivants ont été appliqués rétroactivement aux normes C++ précédemment publiées.
| DR | Appliqué à | Comportement publié | Comportement correct |
|---|---|---|---|
| P0558R1 | C++11 |
une correspondance exacte de type était requise car
T
était déduit de multiples arguments
|
T
est uniquement déduit
de obj |
Voir aussi
|
ajoute atomiquement l'argument à la valeur stockée dans l'objet atomique et obtient la valeur détenue précédemment
(fonction membre publique de
std::atomic<T>
)
|
|
|
(C++11)
(C++11)
|
soustrait une valeur non atomique d'un objet atomique et obtient la valeur précédente de l'atomique
(fonction template) |
|
Documentation C
pour
atomic_fetch_add
,
atomic_fetch_add_explicit
|
|