首先根据: The C++ core guideline 的第 42 条中提到:不要在没有条件的情况下等待( Don’t wait without a condition).主要是为了解决:
下面是范例代码:
#include <condition_variable>
#include <iostream>
#include <thread>
std::mutex mutex_;
std::condition_variable condVar;
bool dataReady{false};
void waitingForWork(){
std::cout << "Waiting " << std::endl;
std::unique_lock<std::mutex> lck(mutex_);
condVar.wait(lck, []{ return dataReady; }); // (4)
std::cout << "Running " << std::endl;
}
void setDataReady(){
{
std::lock_guard<std::mutex> lck(mutex_);
dataReady = true;
}
std::cout << "Data prepared" << std::endl;
condVar.notify_one(); // (3)
}
int main(){
std::cout << std::endl;
std::thread t1(waitingForWork); // (1)
std::thread t2(setDataReady); // (2)
t1.join();
t2.join();
std::cout << std::endl;
}
这里再贴一下搜到的资料里 condition_variable 的处理逻辑:
wait (lck, pred);
其实等价于 while (!pred()) wait(lck);
,它的运行机制如下:
这里我的问题是: 假设运行步骤是这样:
dataReady = true
. 并且 notify_one
了。所以这个时候相当于空白 notify_one了一次。实际上 t1 线程的运行只跟 dataReady
有关,而跟 condition_variable 无关了。那么这次的notify_one
的信号到底去哪里了呢?
不知道我有没有描述清楚问题。有大佬能解答一下吗?
1
chuckzhou 2021-01-26 20:53:30 +08:00
notify_one 会检查是否有 waiter,如果没有,啥也不干就退出了。
|
2
V2WT OP @chuckzhou 假设现在有一个 Thread t3 = t2. 这样一次 notify_one(). 因为修改了标志位置。实际上 t2 t3 这两个线程都会执行。那这个 condition_variable 还有什么用呢?
|