版权声明:本文为博主原创文章,欢迎指点!!! https://blog.csdn.net/allen807733144/article/details/80452453
由于C++11 和 Boost.Thread 都没有提供信号量,但是对于这个简单的东西,有时候使用就是太简单,但是为什么没有,可能他们觉得是这个东西太容易出错了,所以自己实现也不是很复杂。
直接上代码:
#include <condition_variable>
#include <mutex>
class Semaphore
{
public:
Semaphore(unsigned long count = 0) : m_count(count) {}
Semaphore(const Semaphore&) = delete;
Semaphore& operator=(const Semaphore&) = delete;
void Signal()
{
{
std::unique_lock<std::mutex> lock(m_mutex);
++m_count;
}
m_cv_uptr.notify_one();
}
void Wait()
{
std::unique_lock<std::mutex> lock(m_mutex);
while (m_count == 0) { // we may have spurious wakeup!
m_cv_uptr.wait(lock);
}
--m_count;
}
private:
std::mutex m_mutex;
std::condition_variable m_cv_uptr;
unsigned long m_count;
};