|
| |||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
Defined in header <atomic> | ||
template<class T> T atomic_fetch_and(std::atomic<T>* obj, | (1) | (since C++11) |
template<class T> T atomic_fetch_and(volatilestd::atomic<T>* obj, | (2) | (since C++11) |
template<class T> T atomic_fetch_and_explicit(std::atomic<T>* obj, | (3) | (since C++11) |
template<class T> T atomic_fetch_and_explicit(volatilestd::atomic<T>* obj, | (4) | (since C++11) |
Atomically replaces the value pointed byobj with the result of bitwise AND between the old value ofobj andarg. Returns the valueobj held previously.
The operation is performed as if the following is executed:
Ifstd::atomic<T> has nofetch_and member (this member is only provided forintegral types exceptbool), the program is ill-formed.
Contents |
| obj | - | pointer to the atomic object to modify |
| arg | - | the value to bitwise AND to the value stored in the atomic object |
| order | - | the memory synchronization ordering |
The value immediately preceding the effects of this function in themodification order of*obj.
#include <atomic>#include <chrono>#include <functional>#include <iostream>#include <thread> // Binary semaphore for demonstrative purposes only.// This is a simple yet meaningful example: atomic operations// are unnecessary without threads.class Semaphore{std::atomic_char m_signaled;public: Semaphore(bool initial=false){ m_signaled= initial;}// Block until semaphore is signaledvoid take(){while(!std::atomic_fetch_and(&m_signaled,false)){std::this_thread::sleep_for(std::chrono::milliseconds(10));}} void put(){std::atomic_fetch_or(&m_signaled,true);}}; class ThreadedCounter{staticconstint N=100;staticconstint REPORT_INTERVAL=10;int m_count;bool m_done; Semaphore m_count_sem; Semaphore m_print_sem; void count_up(){for(m_count=1; m_count<= N;++m_count)if(m_count% REPORT_INTERVAL==0){if(m_count== N) m_done=true; m_print_sem.put();// signal printing to occur m_count_sem.take();// wait until printing is complete proceeding}std::cout<<"count_up() done\n"; m_done=true; m_print_sem.put();} void print_count(){do{ m_print_sem.take();std::cout<< m_count<<'\n'; m_count_sem.put();}while(!m_done);std::cout<<"print_count() done\n";} public: ThreadedCounter(): m_done(false){}void run(){auto print_thread=std::thread(&ThreadedCounter::print_count, this);auto count_thread=std::thread(&ThreadedCounter::count_up, this); print_thread.join(); count_thread.join();}}; int main(){ ThreadedCounter m_counter; m_counter.run();}
Output:
102030405060708090100print_count() donecount_up() done
The following behavior-changing defect reports were applied retroactively to previously published C++ standards.
| DR | Applied to | Behavior as published | Correct behavior |
|---|---|---|---|
| P0558R1 | C++11 | exact type match was required becauseT was deduced from multiple arguments | T is only deducedfrom obj |
| atomically performs bitwise AND between the argument and the value of the atomic object and obtains the value held previously (public member function of std::atomic<T>)[edit] | |
(C++11)(C++11) | replaces the atomic object with the result of bitwise OR with a non-atomic argument and obtains the previous value of the atomic (function template)[edit] |
(C++11)(C++11) | replaces the atomic object with the result of bitwise XOR with a non-atomic argument and obtains the previous value of the atomic (function template)[edit] |
C documentation foratomic_fetch_and,atomic_fetch_and_explicit | |