我有一个应用程序,我在其中以并行工作线程执行昂贵的计算。为简单起见,我直接从这些线程将结果写入标准输出。
在我更改一些内容以尝试使代码运行得更快之前,它工作得很好。首先,我用 "\n"替换了 std::endl 以防止在每一行之后刷新。我在主程序的 init 部分添加了以下几行:
std::cin.tie(nullptr);
std::ios_base::sync_with_stdio(false);
工作线程代码的基本结构如下所示:
while(true) {
// get data from job queue, protected by unique_lock on std::mutex
// process the data
// print results
{
std::lock_guard<std::mutex> lk(outputMutex_);
std::cout << "print many results" << "\n"; // was originally std::endl
}
}
自从这次“优化”后, worker 的产出偶尔会“混”。即互斥量没有达到预期目的。
为什么会这样?我的理解是只有一个 stdout 流缓冲区,并且数据按顺序到达相应的缓冲区,即使在释放互斥锁之前没有从该缓冲区刷新输出。但似乎并不是这样……
(我意识到在单独的线程中生成输出可能会更好,但是我需要使用另一个队列传回这些结果,这在这里似乎没有必要)
更新:可能我的帖子不够清楚。我不关心结果的顺序。问题是(对于上面的例子)而不是这个:
print many results
print many results
print many results
我有时会:
print many print many results
results
print many results
outputMutex_ 是所有工作线程共享的静态成员。
最佳答案
您正在通过多个线程访问 cout。对其队列的访问受互斥量保护,但需要刷新。这不会自动发生(总是至少 :) )
std::endl
刷新 cout,'\n'
不刷新
或者,您可以使用 std::flush
告诉 cout 刷新:
https://en.cppreference.com/w/cpp/io/manip/flush
尝试:
while(true) {
// get data from job queue, protected by unique_lock on std::mutex
// process the data
// print results
{
std::lock_guard<std::mutex> lk(outputMutex_);
std::cout << "print many results" << "\n"; // not flushed
std::cout << std::flush; // flushed!
std::cout << "print something else" << std::endl; // flushed!
}
}
关于c++ - 来自多个线程的 std::cout,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62347686/