VuoThreadUtilities.cc

Go to the documentation of this file.

 
#include "VuoThreadUtilities.hh"
 
VuoThreadUtilities::Semaphore::Semaphore(void) :
    count(1)
{
}
 
void VuoThreadUtilities::Semaphore::acquire(void)
{
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [this](){ return count > 0; });
    --count;
}
 
void VuoThreadUtilities::Semaphore::release(void)
{
    std::unique_lock<std::mutex> lock(mtx);
    count++;
    lock.unlock();
    cv.notify_one();
}