粗体的简短说明。
我有一个 tbb::task 可以这样总结：
class UpdateTask
: public tbb::task
{
public:
tbb::task* execute()
{
// some work...
if( can_continue() )
{
// make sure this is re-executed
this->recycle_to_reexecute(); //looks like it is deprecated but it's more clear to me
return nullptr; // ? or this? or tbb::empty_task?
}
return nullptr;
}
};
我希望此任务在完成后立即重新安排，直到满足条件为止。 我以这种方式分配此任务：
UpdateTask& updater = *new(tbb::task::allocate_root()) UpdateTask();
虽然不确定它与问题有关。
问题：当我运行代码时，我从 tbb（最新版本，4.1.5）得到断言（在调试中），我找不到让它正常工作的方法。
我已经重新阅读了文档，但我找不到一个简单的例子，而且我不清楚我做错了什么。我做了一些实验：
- 使用我刚刚展示的代码，断言说我应该返回一个任务：
Assertion t_next failed on line 485 of file ...\itbb\src\tbb\custom_scheduler.h Detailed description: reexecution requires that method execute() return another task - 然后，如果我返回这个，断言说应该分配任务：
Assertion t_next->state()==task::allocated failed on line 452 of file ...\itbb\src\tbb\custom_scheduler.h Detailed description: if task::execute() returns task, it must be marked as allo cated - 有疑问，我试图返回一个我动态创建的 tbb::empty_task（以检查），分配为
new(tbb::task::allocate_child()) tbb::empty_task(). 我得到了这条消息的断言Assertion p.ref_count==0 failed on line 107 of file ...\itbb\src\tbb\custom_scheduler.h Detailed description: completion of task caused predecessor's reference count to underflow。
那么，该怎么做呢？我认为这很简单，但找不到它的完成方式。它与任务引用计数有关吗？
更新：这是一个完整的代码，可以很好地近似我所拥有的：
#include <iostream>
#include <atomic>
#include <tbb/tbb.h>
namespace test { class UpdateTask : public tbb::task { public:
UpdateTask() { std::cout << "[UpdateTask]" << std::endl; }
~UpdateTask() { std::cout << "\n[/UpdateTask]" << std::endl; }
tbb::task* execute() { std::cout << "Tick "<< m_count <<std::endl;
++m_count;
// make sure this is re-executed this->recycle_to_reexecute(); //return new(tbb::task::allocate_continuation()) tbb::empty_task(); return nullptr; }
private:
std::atomic<int> m_count;
};
tbb::task_list m_task_list;
void register_update_task() { UpdateTask& updater =
*new(tbb::task::allocate_root()) UpdateTask(); m_task_list.push_back( updater ); }
void run_and_wait() { tbb::task::spawn_root_and_wait( m_task_list ); }
void tbb_test() { register_update_task(); run_and_wait();
}
}
int main()
{
test::tbb_test();
std::cout << "\nEND";
std::cin.ignore();
return 0;
}
所以，在这里我得到了第一个例外，说我应该返回一个任务。在execute()函数中，如果我用评论替换返回，那么它似乎可以工作，但这有两个问题：
- 每次调用执行完成时，我都必须创建一个 empty_task 任务？？？
- 在第一次调用 execute() 之后，主线程被恢复。这不是 spawn_root_and_wait() 应该做的。毕竟任务没有完成并且被正确地重新安排。
我必须得出结论，这也不是正确的方法。