std::counting_semaphore, std::binary_semaphore
来自 cppreference.com
定义在头文件 <semaphore> 中 |
||
template< std::ptrdiff_t LeastMaxValue = /* 实现定义 */ > class counting_semaphore; |
(1) | (自 C++20 起) |
using binary_semaphore = std::counting_semaphore<1>; |
(2) | (自 C++20 起) |
1)
counting_semaphore
是一种轻量级同步原语,可以控制对共享资源的访问。与 std::mutex 不同,counting_semaphore
允许对同一资源进行多个并发访问,至少对于 LeastMaxValue
个并发访问器而言。如果 LeastMaxValue
为负数,则程序格式错误。2)
binary_semaphore
是 std::counting_semaphore
的特化的别名,LeastMaxValue
为 1。实现可能会比 std::counting_semaphore
的默认实现更有效地实现 binary_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.
内容 |
[编辑] 数据成员
成员名称 | 定义 |
counter (私有) |
类型为 std::ptrdiff_t 的内部计数器。 ((仅供说明的成员对象*)) |
[编辑] 成员函数
构造一个 counting_semaphore (公共成员函数) | |
析构 counting_semaphore (公共成员函数) | |
operator= [已删除] |
counting_semaphore 不可赋值(公共成员函数) |
操作 | |
递增内部计数器并解除阻塞获取者 (公共成员函数) | |
递减内部计数器或阻塞,直到它可以递减 (公共成员函数) | |
尝试在不阻塞的情况下递减内部计数器 (公共成员函数) | |
尝试递减内部计数器,阻塞最多持续时间 (公共成员函数) | |
尝试递减内部计数器,阻塞到某个时间点 (公共成员函数) | |
常量 | |
[静态] |
返回内部计数器的最大可能值 (公共静态成员函数) |
[编辑] 注释
顾名思义,LeastMaxValue
是最小最大值,而不是实际最大值。因此 max() 可以返回大于 LeastMaxValue
的值。
与 std::mutex 不同,counting_semaphore
不与执行线程绑定 - 获取信号量可以在与释放信号量不同的线程上发生,例如。对 counting_semaphore
的所有操作可以并发执行,并且与特定的执行线程无关,除了析构函数,它不能并发执行,但可以在不同的线程上执行。
信号量也经常用于信号/通知语义,而不是互斥,方法是将信号量初始化为 0,从而阻塞尝试 acquire() 的接收方,直到通知方通过调用 release(n) 进行“信号”。在这方面,信号量可以被认为是 std::condition_variable 的替代品,通常性能更好。
功能测试 宏 | 值 | Std | 功能 |
---|---|---|---|
__cpp_lib_semaphore |
201907L | (C++20) | std::counting_semaphore , std::binary_semaphore |
[编辑] 示例
运行此代码
#include <chrono> #include <iostream> #include <semaphore> #include <thread> // global binary semaphore instances // object counts are set to zero // objects are in non-signaled state std::binary_semaphore smphSignalMainToThread{0}, smphSignalThreadToMain{0}; void ThreadProc() { // wait for a signal from the main proc // by attempting to decrement the semaphore smphSignalMainToThread.acquire(); // this call blocks until the semaphore's count // is increased from the main proc std::cout << "[thread] Got the signal\n"; // response message // wait for 3 seconds to imitate some work // being done by the thread using namespace std::literals; std::this_thread::sleep_for(3s); std::cout << "[thread] Send the signal\n"; // message // signal the main proc back smphSignalThreadToMain.release(); } int main() { // create some worker thread std::thread thrWorker(ThreadProc); std::cout << "[main] Send the signal\n"; // message // signal the worker thread to start working // by increasing the semaphore's count smphSignalMainToThread.release(); // wait until the worker thread is done doing the work // by attempting to decrement the semaphore's count smphSignalThreadToMain.acquire(); std::cout << "[main] Got the signal\n"; // response message thrWorker.join(); }
输出
[main] Send the signal [thread] Got the signal [thread] Send the signal [main] Got the signal