Boost：两个工作线程，让主线程休眠，直到它们都完成答案

【问题标题】：Boost: Two worker threads, sleep the main thread until they both finishBoost：两个工作线程，让主线程休眠，直到它们都完成
【发布时间】：2012-08-10 09:36:24
【问题描述】：

我使用 Boost 线程编写了一个程序。我已经分配了两个缓冲区（每个工作线程一个）来存储他们要处理的一些信息。他们坐下来等待缓冲区上出现一些东西，然后他们处理它并将结果放到不同的缓冲区中。我的缓冲区实现是线程安全的。目前，我让主线程忙着等待，直到缓冲区大小为零，但这确实效率低下，因为它必须不断请求对缓冲区的控制然后检查大小。我想要一种让主线程休眠的方法，直到两个工作线程都表示它们已完成。我相当肯定这可以使用boost::condition_variable 来实现，但我不确定如何使用两个工作线程来实现。

非常感谢您的帮助。

编辑 - 另外，boost::barrier 也适合吗？

【问题讨论】：

如何在当前设计中提供线程安全？
缓冲区上的 put/get 方法使用互斥体和条件变量。
既然可以使用mutex和cv，为什么不能写wait_until_buffer_empty，使用mutex和cv呢？

标签： c++ multithreading boost boost-thread

【解决方案1】：

你也可以使用 thread::join 方法。此方法将等待线程完成（线程函数返回）。

更多关于join的信息。

我不认为这个障碍可以帮助你。屏障允许停止线程处理，直到所有线程都遇到屏障。当所有线程都调用了barrier::wait后，所有线程停止等待。

【讨论】：

出于速度和清晰度的原因，我希望保持工作线程可用，并尽可能根据需要向它们提供数据。
主线程如何检索数据以提供给处理线程？
它从另一个缓冲区中拉出它，然后将其切成碎片，然后将其提供给工作线程。
“另一个缓冲区”的拉取是否通过线程同步机制完成？

【解决方案2】：

缓冲区大小为 0 似乎是条件变量的谓词。该大小必须以某种方式受到互斥锁的保护。无论您在何处锁定该互斥体以更改缓冲区大小，都必须在大小为零时向条件变量发出信号。

一个新的 wait_for_zero_size() 函数必须锁定互斥体，并在条件不成立时在等待条件变量的循环中查找该谓词：

void buffer::wait_for_zero_size()
{
    boost::mutex::scoped_lock lock( mutex_ );

    while ( size_ != 0 )
        condition_.wait( lock );
}

HTH, 托斯滕

【讨论】：