ТВВ задача блокируется, если не рекурсии дальнейшего

Question

struct root: public task 
{ 
root(){} 
tbb::task* execute(){ 
    tbb::task_list l; 
    tbb::task& c = *new(allocate_continuation()) tbb::empty_task; 
    int count=0; 
    // do what this task should do 
    while(condition){ 
    l.push_back(*new(c.allocate_child())root()); 
    ++count; 
    } 
    if(count){ 
    c.set_ref_count(count); 
    c.spawn(l); 
    } 
    return NULL; 
} 
}; 
main(){ 
    tbb::task_scheduler_init s(); 
    root& r = *new(tbb::task::allocate_root())root(); 
    tbb::task::spawn_root_and_wait(r); 
    return 0; 
} 

Привет, Я определить задачу TBB «корень», что делает некоторую работу и затем рекурсивно дальше, если condition в while цикл выполняется. Если count==0 после цикла while, что означает, что дальнейшая рекурсия не требуется, я не буду генерировать больше задач.

Поскольку задача root не требует продолжения обновления, поэтому я использую tbb::empty_task как задачу продолжения.

Проблема заключается в том, что выполнение блокируется этим. Программа не может нормально вернуться. На данный момент мое решение:

if(!count){ 
    l.push_back(*new(c.allocate_child())tbb::empty_task); 
    c.spawn(l); 
    c.set_ref_count(1); 
} 

Однако, я полагаю, что цена - это производительность. Я хочу знать, почему исходный код не работает. Он работал в другом случае, когда задача продолжения не является пустой задачей. Я не совсем понимаю логику. Спасибо за любые комментарии.

Answer 1

Одна проблема в том, что когда count==0, задача c потеряна, так как у нее нет детей, и она не размножается. Правильный способ освободить задачу - позвонить tbb::task::destroy. Но поскольку вы выделили его в качестве продолжения, ответственность за то, чтобы сообщить об spawn_root_and_wait, что работа выполнена, переносится на задание c. И поскольку задача потеряна, сигнал также теряется, что приводит к тупику, который вы наблюдаете. Чтобы эффективно выполнять сигнализацию для случая count==0, просто верните указатель на эту задачу c в результате root::execute(), который похож на выполнение spawn(c), но позволяет избежать дополнительных накладных расходов для синхронизации.

Альтернатива состоит в том, чтобы сделать c.parent()->decrement_ref_count() и позвонить по телефону destroy(c) вручную.