std:: atomic_flag
From cppreference.net
C++
Concurrency support library
|
|
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
std::atomic_flag
| Member functions | ||||
|
(C++20)
|
||||
|
(C++20)
|
||||
|
(C++20)
|
||||
|
(C++20)
|
|
定义于头文件
<atomic>
|
||
|
class
atomic_flag
;
|
(C++11 起) | |
std::atomic_flag
是一种原子布尔类型。与所有
std::atomic
的特化不同,它保证是无锁的。与
std::
atomic
<
bool
>
不同,
std::atomic_flag
不提供加载或存储操作。
成员函数
|
构造 atomic_flag
(公开成员函数) |
|
|
[deleted]
|
赋值运算符(已删除)
(公开成员函数) |
|
原子地将标志设置为
false
(公开成员函数) |
|
|
原子地将标志设置为
true
并获取其先前值
(公开成员函数) |
|
|
(C++20)
|
原子地返回标志的值
(公开成员函数) |
|
(C++20)
|
阻塞线程直至被通知且原子值发生变化
(公开成员函数) |
|
(C++20)
|
通知至少一个在原子对象上等待的线程
(公开成员函数) |
|
(C++20)
|
通知所有在原子对象上阻塞等待的线程
(公开成员函数) |
示例
一个 自旋锁 互斥量演示可以通过用户空间的 atomic_flag 实现。请注意自旋锁互斥量在实际应用中 极具争议性 。
运行此代码
#include <atomic> #include <iostream> #include <mutex> #include <thread> #include <vector> class mutex { std::atomic_flag m_{}; public: void lock() noexcept { while (m_.test_and_set(std::memory_order_acquire)) #if defined(__cpp_lib_atomic_wait) && __cpp_lib_atomic_wait >= 201907L // Since C++20, locks can be acquired only after notification in the unlock, // avoiding any unnecessary spinning. // Note that even though wait guarantees it returns only after the value has // changed, the lock is acquired after the next condition check. m_.wait(true, std::memory_order_relaxed) #endif ; } bool try_lock() noexcept { return !m_.test_and_set(std::memory_order_acquire); } void unlock() noexcept { m_.clear(std::memory_order_release); #if defined(__cpp_lib_atomic_wait) && __cpp_lib_atomic_wait >= 201907L m_.notify_one(); #endif } }; static mutex m; static int out{}; void f(std::size_t n) { for (std::size_t cnt{}; cnt < 40; ++cnt) { std::lock_guard lock{m}; std::cout << n << ((++out % 40) == 0 ? '\n' : ' '); } } int main() { std::vector<std::thread> v; for (std::size_t n{}; n < 10; ++n) v.emplace_back(f, n); for (auto &t : v) t.join(); }
可能的输出:
0 1 1 2 0 1 3 2 3 2 0 1 2 3 2 3 0 1 3 2 0 1 2 3 2 3 0 3 2 3 2 3 2 3 1 2 3 0 1 3 2 3 2 0 1 2 3 0 1 2 3 2 0 1 2 3 0 1 2 3 2 3 2 3 2 0 1 2 3 2 3 0 1 3 2 3 0 2 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 0 3 2 0 2 3 2 3 2 3 2 3 2 3 0 3 2 3 0 3 0 3 2 3 0 3 2 3 2 3 0 2 3 0 3 2 0 2 2 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9
参见
|
(C++11)
(C++11)
|
原子地将标志设置为
true
并返回其先前值
(函数) |
|
(C++11)
(C++11)
|
原子地将标志值设置为
false
(函数) |
|
(C++20)
(C++20)
|
阻塞线程直至被通知且标志发生变化
(函数) |
|
(C++20)
|
通知在 atomic_flag_wait 中阻塞的线程
(函数) |
|
(C++20)
|
通知所有在 atomic_flag_wait 中阻塞的线程
(函数) |
|
(C++11)
|
将
std::atomic_flag
初始化为
false
(宏常量) |
|
C 文档
for
atomic_flag
|
|