等待多个信号 - pthread

Question

我正在构建一个简单的作业系统，它允许我创建一个具有依赖关系的作业图...类似于：

Job root;
Job job1;
Job job1_1;
Job job1_2;
Job job2(&job1, 1); // job2 cannot start until job1 finishes.

job1.addJob(&job1_1);
job1.addJob(&job1_2);
root.addJob(&job1);
root.addJob(&job2);

root.execute(); // execute the job graph.

我正在使用 pthreads 来实现这个，但我是这种类型的程序的新手，我找不到同步所有这些的方法。

我尝试使用 pthread_join 来做这样的事情：

void Job::execute()
{
    for(int i = 0; i < numDependencies; ++i)
        dependencies[i].join(); // calling pthread_join

    for(int i = 0; i < numSubJobs; ++i)
        subJobs[i].start(); // calling pthread_create

    ... do some work here

    for(int i = 0; i < numSubJobs; ++i)
        subJobs[i].join(); // calling pthread_join
}

但是我的程序在其中一个 pthread_join 调用中崩溃了。

来自 pthread 文档：

多次同时调用 pthread_join() 的结果 指定相同的目标线程是未定义的。

我怎样才能获得相同的结果但又不会崩溃？

谢谢

Answer 1

pthred_join() 等待创建的线程终止。程序崩溃是因为您使用的是 Job 的未初始化成员（假设 pthread_t thread; ）。如果作业线程是在 start() 方法中创建的，那么您应该将execute() 重写为：

void Job::execute()
{
    for(int i = 0; i < numDependencies; ++i)
        dependencies[i].start(); // calling pthread_create

    for(int i = 0; i < numDependencies; ++i)
        dependencies[i].join(); // calling pthread_join
...

在这种情况下，您将不会得到*多个同时调用 pthread_join() 指定相同的目标线程*（而且这不是问题）你的情况也是如此）。