std::atomic_fetch_and, std::atomic_fetch_and_explicit
来自 cppreference.com
定义在头文件 <atomic> 中 |
||
template< class T > T atomic_fetch_and( std::atomic<T>* obj, |
(1) | (自 C++11 起) |
template< class T > T atomic_fetch_and( volatile std::atomic<T>* obj, |
(2) | (自 C++11 起) |
template< class T > T atomic_fetch_and_explicit( std::atomic<T>* obj, |
(3) | (自 C++11 起) |
template< class T > T atomic_fetch_and_explicit( volatile std::atomic<T>* obj, |
(4) | (自 C++11 起) |
原子地用 obj 指向的值与 obj 的旧值与 arg 的按位与运算结果替换。返回 obj 之前持有的值。
操作执行的步骤与执行以下代码相同
1,2) obj->fetch_and(arg)
3,4) obj->fetch_and(arg, order)
如果 std::atomic<T>
没有 fetch_and
成员(此成员只提供给除 bool 之外的整数类型),则程序格式错误。
内容 |
[编辑] 参数
obj | - | 指向要修改的原子对象的指针 |
arg | - | 要对存储在原子对象中的值执行按位与运算的值 |
order | - | 内存同步排序 |
[编辑] 返回值
在 *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 signaled void 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 { static const int N = 100; static const int 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(); }
输出
10 20 30 40 50 60 70 80 90 100 print_count() done count_up() done
[编辑] 缺陷报告
以下更改行为的缺陷报告已追溯应用到先前发布的 C++ 标准。
DR | 应用于 | 已发布的行为 | 正确行为 |
---|---|---|---|
P0558R1 | C++11 | 需要精确类型匹配,因为T 是从多个参数推断出来的 |
T 仅从obj 中推断出来 |
[编辑] 参见
原子地执行参数与原子对象的值的按位与运算,并获取先前持有的值 ( std::atomic<T> 的公共成员函数) | |
(C++11)(C++11) |
用与非原子参数的按位或运算结果替换原子对象,并获取原子的先前值 (函数模板) |
(C++11)(C++11) |
用与非原子参数的按位异或运算结果替换原子对象,并获取原子的先前值 (函数模板) |
C 文档 for atomic_fetch_and, atomic_fetch_and_explicit
|