Планирование выполнения во время выполнения Windows с исключениями
В соответствии с MSDN,
Продолжение на основе задачи всегда запланировано для выполнения, когда завершается предшествующая задача, даже если предшествующая задача отменена или бросает исключение.
Я не понимаю этого, потому что я опробовал следующий код, и последующее задание не вызывается, когда первое задание завершается с помощью исключения. Я понимаю, почему он должен переадресовать звонок на сайт, где concurrency::task::wait называется, но я не понимаю, что означает утверждение на MSDN. Что я недопонимаю?
#include <iostream>
#include <ppl.h>
#include <ppltasks.h>
int main(int argc, char* argv[])
{
using namespace std;
concurrency::task<void> task;
auto task_ticket = concurrency::create_task([]()
{
// A continuation task executed asynchronously
// after the previous task has completed. This
// is executed even if the previous task fails
// by being cancelled or throwing an exception.
throw std::runtime_error("Hello");
})
.then([]()
{
// This should be executed even though the
// previous task failed.
cout << "Task (2) executed" << endl;
});
try
{
task_ticket.wait();
}
catch (std::exception const& e)
{
cout << "Exception caught\n";
}
return EXIT_SUCCESS;
}
Решение
Вы недоразумение Основанные на ценностях и основанные на задачах продолжения.
Учитывая объект задачи, тип возвращаемого значения которого T, вы можете предоставить значение типа T или задачу для ее задач продолжения. Продолжение, которое принимает тип T, известно как продолжение на основе значений.
Ваш первоначальный вызов create_task возвращается task<void>, Лямбда, к которой вы переходите .then принимает void как вход (так как .then([]() эквивалентно .then([](void)), следовательно, продолжение основано на значении и не запускается, если выбрасывается предшествующая задача.
Чтобы объявить продолжение на основе задач, используйте:
auto task_ticket = concurrency::create_task([]()
{
throw std::runtime_error("Hello");
})
.then([](task<void> antecedent_task)
{
cout << "Task (2) executed" << endl;
antecedent_task.get(); // re-throws std::runtime_error
});
Другие решения
Других решений пока нет …
detector