从线程调用 add_thread 时提升 thread_group 块，为什么？

Question

我编写了一个类似于以下结构的多线程程序（我省略了互斥锁和无关代码），当从线程调用时，它会阻塞对boost::thread_group.add_thread() 的调用。有没有办法解决这个问题，所以调用不会阻塞？

boost::thread_group group;

void threaded_function2()
{
}

void threaded_function()
{
    if( condition)
    {
        boost::thread *t3 = new boost::thread( boost::bind( &threaded_function2));
        group.add_thread( t3); // <-- Blocks on this call
    }
}

int main()
{
    boost::thread *t1 = new boost::thread( boost::bind( &threaded_function));
    boost::thread *t2 = new boost::thread( boost::bind( &threaded_function));
    group.add_thread( t1);
    group.add_thread( t2);

    group.join_all();
    return 0;
}

谢谢大家。

Answer 1

如果我错了，请纠正我，但这里可能发生的是 join_all 调用在线程被添加之前运行，使得 thread_group 对象阻塞，直到其他线程被释放。一种解决方案是在 main 函数上创建一个互斥体，以等待 threaded_function 完成以调用 join_all 方法。不过，这是糟糕的设计。