void my_func() {
    my_recusive_func (0);
}

bool doSomeWork (int i,int& a,int& b,int& c) {
    // do some work
}

void my_recusive_func (int i) {
    int a,b,c;
    bool notDone = doSomeWork (i,a,c);
    if (notDone) {
        my_recusive_func (a);
        my_recusive_func (b);
        my_recusive_func (c);
    }
}

我是一个tbb新手所以我的第一次尝试使用了parallel_invoke函数：

void my_recusive_func (int i) {
    int a,c);
    if (notDone) {
        tbb::parallel_invoke (
                [a]{my_recusive_func (a);},[b]{my_recusive_func (b);},[c]{my_recusive_func (c);});
    }
}

这确实有效,并且运行速度比单线程版本快,但它似乎不能很好地扩展核心数量.我所针对的机器有16个内核(32个超线程),因此可伸缩性对于这个项目非常重要,但是这个版本在该机器上最多只能获得8倍的加速,并且在算法运行时许多内核似乎处于空闲状态.

我的理论是tbb正在等待parallel_invoke之后的子任务完成所以可能有许多任务闲置等待不必要？这会解释空闲核心吗？有没有办法让父任务返回而不等待孩子？我当时想的可能是这样的,但我还不知道调度程序还不知道这是否正常：

void my_func()
{
    tbb::task_group g;
    my_recusive_func (0,g);
    g.wait();
}

void my_recusive_func (int i,tbb::task_group& g) {
    int a,c);
    if (notDone) {
        g.run([a,&g]{my_recusive_func(a,g);});
        g.run([b,&g]{my_recusive_func(b,g);});
        my_recusive_func (c,g);
    }
}

我的第一个问题是tbb :: task_group :: run()线程安全吗？我无法从文档中找到答案.此外,还有更好的方法来解决这个问题吗？也许我应该使用低级调度程序调用？

(我输入的代码没有编译,所以请原谅错别字.)