C++11實現訊號量
阿新 • • 發佈:2018-11-25
由於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; };