То, что я хочу в основном выполнить, - это запланировать новые рабочие элементы task_group по мере того, как работа станет доступной. В task_group метод run () вызывается в сценарии производителя-потребителя - так что в любой момент, когда необходима работа, он запланирован для запуска в task_group
Concurrency::task_group taskGroup;
tempalte <typename Functor>
void queue_work(Functor& fn)
{
taskGroup.run([&fn](){
fn();
});
}
task_group требует (перед выходом из приложения), чтобы был вызван метод wait () для освобождения ресурсов. Я использую task_group, потому что мне также нужна поддержка отмены, но необходимость вызова wait () усложняет дизайн. На практике кажется, что мне нужно будет использовать дополнительный поток, из которого время от времени будет вызывать wait () в группе задач (не знаю, законно ли планировать новую работу в task_group после однократного вызова wait () или делать wait () несколько раз).
Как бы вы это сделали, используя PPL от Microsoft?
ИЗМЕНИТЬ В документации MSDN указано, что вызов wait () разрешен несколько раз: http://msdn.microsoft.com/en-us/library/dd470481.aspx" Вызов wait для объекта task_group сбрасывает его в чистое состояние, где его можно использовать повторно. Это включает случай, когда объект task_group был отменен. "
Единственное, что осталось бы, если бы можно было выбрать другой подход
