时间戳

首页 > 解决方案 > std::condition_variable::wait() 误解

c++ - std::condition_variable::wait() 误解

问题描述

为什么必须 在此代码while()中使用with ：std::condition_variable::wait()

#include <iostream>           // std::cout
#include <thread>             // std::thread
#include <mutex>              // std::mutex, std::unique_lock
#include <condition_variable> // std::condition_variable

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void print_id (int id) {
  std::unique_lock<std::mutex> lck(mtx);
  while (!ready) cv.wait(lck);
  // ...
  std::cout << "thread " << id << '\n';
}

void go() {
  std::unique_lock<std::mutex> lck(mtx);
  ready = true;
  cv.notify_all();
}

int main ()
{
  std::thread threads[10];
  // spawn 10 threads:
  for (int i=0; i<10; ++i)
    threads[i] = std::thread(print_id,i);

  std::cout << "10 threads ready to race...\n";
  go();                       // go!

  for (auto& th : threads) th.join();

  return 0;
}

据我了解，如果std::condition_variable::wait()阻塞当前线程，并且该线程正在等待暂停，直到另一个线程正在调用 notify..() 函数

标签： c++multithreadingwait

解决方案

为什么有必要将 while() 与 std::condition_variable::wait() 一起使用

wait可以返回是否ready为真。如果我们只想在ready为真时继续，那么我们必须检查它，并继续等待以防万一。循环是一种方便的控制结构，用于重复操作直到满足条件。

为什么 wait() 可能看似虚假地返回

因为标准说它可能：

效果：

  • 在 *this 上原子地调用lock.unlock()和阻塞。
  • 当解除阻塞时，调用lock.lock(（可能在锁上阻塞），然后返回。
  • notify_­one()当通过调用或调用或虚假notify_­all()发出信号时，该函数将解除阻塞。

推荐阅读