使用TBB执行订单



我想要类似tbb::task_group的东西,但有保证订单执行的差异,例如

serial_task_group tasks;
tasks.run([]{std::cout << 1;});
tasks.run([]{std::cout << 2;});
tasks.run([]{std::cout << 3;});
tasks.wait();
// guaranteed output: 123

关于如何使用 tbb 实现这一目标的任何建议?

目前我有一个显式线程,它只是使用条件变量从队列中执行。但是,使用队列的问题在于我将如何保证 task_group中只有一个任务处于活动状态。

(披露:我在英特尔从事英特尔线程构建模块的工作。

正如另一个答案中所建议的那样,您可以使用流图来执行类似的事情。 使用流图的示例代码如下所示:

#include "tbb/flow_graph.h"
#include <iostream>
using namespace tbb::flow;
int main( int argc, char *argv[] ) {
    graph g;
    continue_node< continue_msg > n1( g, []( const continue_msg & ) { std::cout << "1"; } );
    continue_node< continue_msg > n2( g, []( const continue_msg & ) { std::cout << "2"; } );
    continue_node< continue_msg > n3( g, []( const continue_msg & ) { std::cout << "3"; } );
    make_edge( n1, n2 );
    make_edge( n2, n3 );
    n1.try_put( continue_msg() );
    g.wait_for_all();
   return 0;
}

最新更新