1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
#ifndef _LOCKABLE_H
#define _LOCKABLE_H
#include <mutex>
#include <condition_variable>
namespace acng
{
typedef std::mutex acmutex;
struct base_with_mutex
{
std::mutex m_obj_mutex;
};
// little adapter for more convenient use
struct lockguard {
std::lock_guard<std::mutex> _guard;
lockguard(std::mutex& mx) : _guard(mx) {}
lockguard(std::mutex* mx) : _guard(*mx) {}
lockguard(base_with_mutex& mbase) : _guard(mbase.m_obj_mutex) {}
lockguard(base_with_mutex* mbase) : _guard(mbase->m_obj_mutex) {}
};
struct lockuniq {
std::unique_lock<std::mutex> _guard;
lockuniq(std::mutex& mx) : _guard(mx) {}
lockuniq(base_with_mutex& mbase) : _guard(mbase.m_obj_mutex) {}
lockuniq(base_with_mutex* mbase) : _guard(mbase->m_obj_mutex) {}
void unLock() { _guard.unlock();}
void reLock() { _guard.lock(); }
void reLockSafe() { if(!_guard.owns_lock()) _guard.lock(); }
};
struct base_with_condition : public base_with_mutex
{
std::condition_variable m_obj_cond;
void notifyAll() { m_obj_cond.notify_all(); }
void wait(lockuniq& uli) { m_obj_cond.wait(uli._guard); }
bool wait_until(lockuniq& uli, time_t nUTCsecs, long msec);
bool wait_for(lockuniq& uli, long secs, long msec);
};
#define setLockGuard std::lock_guard<std::mutex> local_helper_lockguard(m_obj_mutex);
}
#endif
|
