Планирование выполнения во время выполнения Windows с исключениями

Question

Согласно 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;
}

Answer 1

Вы не понимаете, что основано на ценностях, а не на задачах.

Учитывая объект задачи, тип возвращаемого значения которого 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
});