C++中唯一锁、互斥量和条件变量的关系

Question

你好我有以下代码：

// condition_variable example
#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> lock(mtx);
  while (!ready) cv.wait(lock);
  // ...
  std::cout << "thread " << id << '\n';
}

void go() {
  std::unique_lock<std::mutex> lock(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();
  std::cout << "Finished!" << std::endl;

  return 0;
}

如果我删除 main 中函数调用 go() 的注释，我会得到以下输出：

10 threads ready to race...
thread 0
thread 8
thread 1
thread 2
thread 4
thread 5
thread 3
thread 6
thread 7
thread 9
Finished!

我完全理解为什么我得到这个输出的一些流程。但是，我不明白为什么如果我注释掉 main 中的 go() 函数调用，我无法打印“10 个线程准备竞赛...”。如果我理解正确的话，我没有通过不调用 go() 来调用 notification_all()，因此线程不会唤醒，但为什么打印函数“10 个线程准备好竞赛...”也没有被调用？

另外，请解释为什么我需要调用 std::unique_lock lock(mtx); 在 go() 函数内部。感谢你们！

顺便说一句，只是为了引用，我在以下位置得到了这个例子： http: //www.cplusplus.com/reference/condition_variable/condition_variable/

Answer 1

标准输出被缓冲。这意味着每个输出操作不会单独发送到父进程，而是聚集在内存中并批量发送。这样做是为了最大限度地减少系统调用/进程间通信的开销 - 或任何输出所需的开销。

当缓冲区被填满时，它将被刷新，并且只有当它被刷新时你才能看到任何输出。显然10 threads ready to race...不足以填充缓冲区。

std::flush当程序结束时，或者当访问标准输入时，或者如果您使用或显式请求时，缓冲区也会被刷新std::endl。

当您的程序无限期地等待其他线程（处于死锁状态）时，它永远不会达到缓冲区被进一步填充并最终刷新的程度。