互斥量、信号量、条件变量,三者之间的互相实现
namespace bigcat {
class mutex {
private:
semaphore sem = semaphore(1);
public:
void wait() {
sem.wait();
}
void notify() {
sem.notify();
}
};
class semaphore {
private:
condition_variable cv;
mutex mtx;
unsigned int count;
public:
semaphore(unsigned int n) : count(n) {};
void wait() {
mtx.lock();
while(!count) cv.wait(mtx);
count--;
mtx.unlock();
}
void notify() {
mtx.lock();
count++;
mtx.unlock();
cv.notify_all();
}
};
class condition_variable {
private:
semaphore sem = semaphore(0);
mutex mtx_count;
unsigned int wait_count = 0;
public:
void wait(mutex &mtx) {
mtx.unlock();
mtx_count.lock();
wait_count++;
mtx_count.unlock();
sem.wait();
mtx.lock();
}
void notify() {
mtx_count.lock();
if(wait_count) {
wait_count--;
}
sem.notify();
mtx_count.unlock();
}
void notify_all() {
mtx_count.lock();
for(; wait_count; wait_count--) {
sem.notify();
}
mtx_count.unlock();
}
};
}
值一提的是:C++20 以前(不包含 C++20)的线程相关库并不支持信号量,于是可以通过这种形式来实现。最简单快捷的方法还是直接使用系统的 API,但这会降低可移植性,需要做出一定取舍。
- 信号量→互斥量
- 互斥量+信号量→条件变量
- 条件变量+互斥量→信号量
如果只允许操作系统实现三种其中一种,那么显然单独信号量就足以实现其他两种设施。这种意义上信号量确实是最基础的设施。信号量从直观上是一个计数器加上一个“休眠本任务/唤醒其它任务”的机制。它是系统内核中的任务调度控制机构在用户层的最简单体现。