1

我想用tbb::tasks 并行化一个看似简单的问题。我的任务可以拆分成子任务，子任务的数量不能选择，而是由任务的状态决定的（事先不知道）。由于父任务不需要其子任务的结果，我想将父任务作为子任务回收。我在在线文档或示例中找不到一个很好的工作示例，因此我的问题在这里。我目前的想法是按照以下思路编写代码：

struct my_task : tbb::task {
  typedef implementation_defined task_data;
  task_data DATA;
  my_task(task_data const&data) : DATA(data) {}
  void reset_state(task_data const&data) { DATA=data; }
  bool is_small() const;
  void serial_execution();
  bool has_more_sub_tasks() const;
  task_data parameters_for_next_sub_task();
  tbb::task*execute()
  {
    if(is_small()) {
      serial_execution();
      return nullptr;
    }
    tbb::empty_task&Continuation = allocate_continuation();     // <-- correct?
    task_data first_sub_task = parameters_for_next_sub_task();
    int sub_task_counter = 1;
    tbb::task_list further_sub_tasks;
    for(; has_more_sub_tasks(); ++sub_task_counter)
        further_sub_tasks.push_back(*new(Continuation.allocate_child())
                                     my_task(parameters_for_next_sub_task());
    Continuation.set_ref_count(sub_task_counter);               // <-- correct?
    spawn(further_sub_tasks);
    recycle_as_child_of(Continuation);                          // <-- correct?
    reset_state(first_sub_task);                                // change state
    return this;                                                // <-- correct?
  }
};

my_task*root_task = new(tbb::task::allocate_root())
                    my_task(parameters_for_root_task());
tbb::task::spawn_root_and_wait(*root_task);

这是正确的和/或最好的方法吗？（请注意，在我上面的代码中，空的延续任务既没有产生也没有返回）

4

1 回答 1

2

创建延续的行应该是：

tbb::empty_task&Continuation = *new( allocate_continuation() ) tbb::empty_task;

set_ref_count 和 reset_state 之间的逻辑看起来是正确的。

于 2013-03-22T15:45:36.713 回答