c++ - 在线程中等待一段时间，或者直到条件发生

Question

我正在用 C++ 编写一个服务，并且我有一些线程需要在给定的时间内休眠。

目前一切顺利，boost::this_thread::sleep_for 可以正常工作，但我现在需要一些中断(例如，停止信号)。 Boost 没有cancellation_token，到目前为止我有如下内容:

boost::mutex _waiting_mutex;
boost::condition_variable _waiting_cv;

void wait(const boost::chrono::duration& timeout)
{
    boost::unique_lock<boost::mutex> lk(_waiting_mutex);
    _waiting_cv.wait_for(lk, timeout); 
}

void signal_termination()
{
    _waiting_cv.notify_all();
}

这适用于一个线程(休眠 5 秒，或直到 signal_termination() 被调用)，但不适用于多个线程 - 第一个线程睡得很好，但第二个等待第一个线程离开锁，然后休眠。

如何克服这个unique_lock？我应该引入最大线程数的信号量吗？

在 C# 中，我会使用 ManualResetEvent。

Answer 1

我不确定你是如何针对多线程测试它的，但你得到了错误的结果。条件变量 wait() 或 wait_for() 调用在等待信号时解锁互斥量。否则为什么你必须将锁传递给该函数？

Notice that the lock is passed to wait: wait will atomically add the thread to the set of threads waiting on the condition variable, and unlock the mutex. When the thread is woken, the mutex will be locked again before the call to wait returns. This allows other threads to acquire the mutex in order to update the shared data, and ensures that the data associated with the condition is correctly synchronized.