CGII/framework/include/cgv/os/mutex_std_thread.h

131 lines
2.7 KiB
C
Raw Normal View History

2018-05-17 14:01:02 +00:00
#include "mutex.h"
#include "common_std_thread.h"
#include <iostream>
namespace cgv {
namespace os {
unsigned& ref_debug_lock_counter()
{
static unsigned counter = 0;
return counter;
}
mutex& ref_debug_mutex()
{
static mutex m;
return m;
}
/// return the global locking counter that is used for mutex debugging
unsigned mutex::get_debug_lock_counter()
{
return ref_debug_lock_counter();
}
///construct a mutex
mutex::mutex()
{
Mutex*& m_ptr = ((Mutex*&) pmutex);
m_ptr = new Mutex();
}
///destruct a mutex
mutex::~mutex()
{
Mutex*& m_ptr = ((Mutex*&) pmutex);
delete m_ptr;
}
///lock the mutex (if the mutex is still locked, the caller is blocked until the
///mutex becomes available)
void mutex::lock()
{
Mutex& m = *((Mutex*&) pmutex);
m.lock();
}
///unlock the mutex
void mutex::unlock()
{
Mutex& m = *((Mutex*&) pmutex);
m.unlock();
}
/// same as lock but with printing debug information
void mutex::debug_lock(const std::string& info)
{
ref_debug_mutex().lock();
std::cout << info << ": wait for lock [" << this << ":" << get_debug_lock_counter() << "]" << std::endl;
++ref_debug_lock_counter();
ref_debug_mutex().unlock();
lock();
ref_debug_mutex().lock();
std::cout << info << ": received lock [" << this << "]" << std::endl;
ref_debug_mutex().unlock();
}
/// same unlock but with printing debug information
void mutex::debug_unlock(const std::string& info)
{
unlock();
ref_debug_mutex().lock();
std::cout << info << ": unlock [" << this << "]" << std::endl;
ref_debug_mutex().unlock();
}
///try to lock the mutex (return false if the mutex is still locked)
bool mutex::try_lock()
{
Mutex& m = *((Mutex*&) pmutex);
return m.try_lock();
}
///construct a mutex
condition_mutex::condition_mutex()
{
Mutex& m = *((Mutex*&) pmutex);
Condition*& c_ptr = (Condition*&) pcond;
c_ptr = new Condition(m);
}
///destruct a mutex
condition_mutex::~condition_mutex()
{
Condition*& c_ptr = (Condition*&) pcond;
delete c_ptr;
}
/// send the signal to unblock a thread waiting for the condition represented by this condition_mutex
void condition_mutex::send_signal()
{
Condition& c = *((Condition*&) pcond);
c.cv.notify_one();
}
/// prefered approach to send the signal and implemented as {lock();send_signal();unlock();}
void condition_mutex::send_signal_with_lock()
{
lock();
send_signal();
unlock();
}
/// broadcast signal to unblock several threads waiting for the condition represented by this condition_mutex
void condition_mutex::broadcast_signal()
{
Condition& c = *((Condition*&) pcond);
c.cv.notify_all();
}
/// prefered approach to broadcast the signal and implemented as {lock();broadcast_signal();unlock();}
void condition_mutex::broadcast_signal_with_lock()
{
lock();
broadcast_signal();
unlock();
}
}
}