为什么 std::condition_variable wait() 需要 std::unique_lock arg？

Question

我的线程不需要被锁定。 std::unique_lock 在构造时锁定线程。我只是使用 cond_var.wait() 作为避免繁忙等待的方法。我基本上通过将 unique_lock 放在一个很小的范围内来规避自动锁定，从而在它离开这个小范围后销毁唯一锁。此外，如果相关的话，只有一个消费者线程。

{
std::unique_lock<std::mutex> dispatch_ul(dispatch_mtx);
pq_cond.wait(dispatch_ul);
}

是否有更好的选择来避免 unique_lock 不必要的自动锁定功能？我正在寻找一个无互斥选项来简单地向线程发出信号，我知道 std:: condition_variable_any 但这需要某种互斥体，这在我的情况下又是不必要的。

Answer 1

你需要一个锁来防止这种常见的新手错误：

1. 生产者线程生产一些东西，
2. 生产者线程调用 some_condition.notify_all()，
3. 生产者线程空闲一段时间，

同时：

4. 消费者线程调用 some_condition。 wait(...)
5. 消费者线程等待，...
6. 并且等待，...
7. 并且等待。

条件变量不是标志。它不记得它已被通知。如果生产者在消费者进入 wait() 调用之前调用 notify_one() 或 notify_all()，那么通知就“丢失”了。

为了防止丢失通知，必须有一些共享数据告诉消费者是否需要等待，并且必须有一个锁来保护共享数据。

生产者应该：

1. 锁定锁，
2. 更新共享数据，
3. 通知条件变量，
4. 释放锁

消费者必须：

1. 锁定锁，
2. 检查共享数据是否需要等待，
3. 如果需要，
4. 消耗任何东西，
5. 释放锁。

消费者需要将锁传递给 wait(...) 调用，以便 wait(...) 可以暂时解锁它，然后重新锁定它返回之前。如果 wait(...) 没有解锁锁，那么生产者将永远无法到达 notify() 调用。