semaphore.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_DATATASK_SEMAPHORE_HPP
#define RTCTK_DATATASK_SEMAPHORE_HPP
 
#include <condition_variable>
#include <mutex>
#include <stdexcept>
 
namespace rtctk::dataTask {
 
class [[deprecated]] Semaphore {
public:
    Semaphore(int count = 0) : m_count(count) {
    }
 
    inline void Post() {  // Signal
        {
            std::unique_lock<std::mutex> lock(m_mtx);
            ++m_count;
        }
        m_cv.notify_one();
    }
 
    inline void Wait() {  // Wait
        std::unique_lock<std::mutex> lock(m_mtx);
        m_cv.wait(lock, [&] { return m_count != 0; });
        --m_count;
    }
 
    template <class Rep, class Period>
    inline void Wait(std::chrono::duration<Rep, Period> timeout) {
        std::unique_lock<std::mutex> lock(m_mtx);
        auto ret = m_cv.wait_for(lock, timeout, [&] { return m_count != 0; });
        if (ret == false) {
            throw(std::runtime_error("Semaphore.Wait() timed out"));
        }
        --m_count;
    }
 
    inline bool TryWait() {
        std::unique_lock<std::mutex> lock(m_mtx);
        bool ret = false;
        if (m_count > 0) {
            --m_count;
            ret = true;
        }
        return ret;
    }
 
    inline void Clear() {
        std::unique_lock<std::mutex> lock(m_mtx);
        m_count = 0;
    }
 
private:
    int m_count;
    std::mutex m_mtx;
    std::condition_variable m_cv;
};
 
}  // namespace rtctk::dataTask
 
#endif  // RTCTK_DATATASK_SEMAPHORE_HPP