src/rt/sync/lock_and_signal.h


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

// -*- c++ -*-
#ifndef LOCK_AND_SIGNAL_H
#define LOCK_AND_SIGNAL_H

class lock_and_signal {
#if defined(__WIN32__)
    HANDLE _event;
    CRITICAL_SECTION _cs;
    DWORD _holding_thread;
#else
    pthread_cond_t _cond;
    pthread_mutex_t _mutex;

    pthread_t _holding_thread;
#endif
    bool _locked;

    bool alive;

public:
    lock_and_signal();
    virtual ~lock_and_signal();

    void lock();
    void unlock();
    void wait();
    bool timed_wait(size_t timeout_in_ns);
    void signal();
    void signal_all();

    bool lock_held_by_current_thread();
};

class scoped_lock {
  lock_and_signal &lock;

public:
  scoped_lock(lock_and_signal &lock);
  ~scoped_lock();
};

#endif /* LOCK_AND_SIGNAL_H */