C++ 参考手册
- C++11
- C++14
- C++17
- C++20
- C++ 编译器支持情况表
- 独立与宿主实现
- C++ 语言
- C++ 关键词
- 预处理器
- C++ 标准库头文件
- 具名要求
- 功能特性测试 (C++20)
- 工具库
- 类型支持(基本类型、RTTI、类型特性)
- 概念库 (C++20)
- 错误处理
- 动态内存管理
- 日期和时间工具
- 字符串库
- 容器库
- 迭代器库
- 范围库 (C++20)
- 算法库
- 数值库
- 输入/输出库
- 文件系统库
- 本地化库
- 正则表达式库
- 原子操作库
- 线程支持库
- std::thread
- std::stop_token
- std::stop_source
- std::stop_callback
- std::this_thread::get_id
- std::shared_timed_mutex
- std::shared_lock
- std::lock_guard
- std::hardware_destructive_interference_size, std::hardware_constructive_interference_size
- std::counting_semaphore, std::binary_semaphore
- std::jthread
- cpp/thread/barrier
- std::future
- std::this_thread::yield
- std::this_thread::sleep_for
- std::this_thread::sleep_until
- std::mutex
- std::recursive_mutex
- std::shared_mutex
- std::timed_mutex
- std::recursive_timed_mutex
- std::scoped_lock
- std::unique_lock
- std::defer_lock_t, std::try_to_lock_t, std::adopt_lock_t
- std::lock
- std::try_lock
- std::defer_lock, std::try_to_lock, std::adopt_lock
- std::once_flag
- std::call_once
- std::condition_variable
- std::condition_variable_any
- std::notify_all_at_thread_exit
- std::cv_status
- std::latch
- std::promise
- std::shared_future
- std::packaged_task
- std::async
- std::launch
- std::future_status
- std::future_error
- std::future_category
- std::future_errc
- 注释
- 实验性 C++ 特性
- 有用的资源
- 索引
- std 符号索引
- 协程支持 (C++20)
- C++ 关键词
std::counting_semaphore, std::binary_semaphore
定义于头文件 <semaphore>
|
||
template<std::ptrdiff_t LeastMaxValue = /* implementation-defined */> class counting_semaphore; |
(1) | (C++20 起) |
using binary_semaphore = std::counting_semaphore<1>; |
(2) | (C++20 起) |
counting_semaphore
是一个轻量同步元件,能控制对共享资源的访问。不同于 std::mutex 、 counting_semaphore
允许同一资源有多于一个同时访问,至少允许 LeastMaxValue
个同时的访问者若LeastMaxValue
为负则程序为谬构。binary_semaphore
是 std::counting_semaphore 的特化的别名,其 LeastMaxValue
为 1 。实现可能将 binary_semaphore
实现得比 std::counting_semaphore 的默认实现更高效。counting_semaphore
含有由构造函数初始化的内部计数器。由调用 acquire() 与相关方法减少此计数器,而它通过调用 release() 增加。计数器为零时, acquire() 阻塞该计数器直至它增加,但 try_acquire() 不阻塞; try_acquire_for() 与 try_acquire_until() 阻塞直至计数器增加或到达时限。
类似 std::condition_variable 的 wait() , counting_semaphore
的 try_acquire() 可能虚假地失败。
模板类 std::counting_semaphore
非可默认构造 (DefaultConstructible) 、可复制构造 (CopyConstructible) 、可移动构造 (MoveConstructible) 、可复制赋值 (CopyAssignable) 或可移动赋值 (MoveAssignable) 。
成员函数
构造 counting_semaphore (公开成员函数) | |
销毁 counting_semaphore (公开成员函数) | |
operator= [被删除] |
counting_semaphore 不可赋值 (公开成员函数) |
操作 | |
增加内部计数器并除阻获取者 (公开成员函数) | |
减少内部计数器或阻塞到直至能如此 (公开成员函数) | |
尝试减少内部计数器而不阻塞 (公开成员函数) | |
尝试减少内部计数器,至多阻塞一段时长 (公开成员函数) | |
尝试减少内部计数器,阻塞直至一个时间点 (公开成员函数) | |
常量 | |
[静态] |
返回内部计数器的最大可能值 (公开静态成员函数) |
注解
如其名所示, LeastMaxValue
是最小的最大值,而非实际最大值。从而 max() 能产生大于 LeastMaxValue
的值。
不同于 std::mutex , counting_semaphore
不捆绑到执行线程——能在不同于释放信号量的线程获取该信号量。能同时进行 counting_semaphore
上的所有操作而无需联系到任何特定的执行线程,除了不能同时执行,但能在一个不同的线程上执行析构函数。
信号量亦常用于发信/提醒而非互斥,通过初始化该信号量为 0 从而阻塞尝试 acquire() 的接收者,直至提醒者通过调用 release(n) “发信”。在此方面可把信号量当作 std::condition_variable 的替用品,通常它有更好的性能。
示例
本节未完成 原因:暂无示例 |