c++ - 如何在卡萨布兰卡捕获多个任务的异常

Question

我正在尝试使用 && operator 加入两个 pplx 任务任务，其中两个子任务都可以抛出异常。

我从 ppl documentation 了解到我可以在最终的、基于任务的延续中捕获异常。这在卡萨布兰卡也适用。然而，我在最后的延续中只能捕获一个异常。如果两个子任务都抛出，则其中一个子任务仍未处理。

这是一个说明我的问题的最小示例:

#include <pplx/pplxtasks.h>
#include <iostream>

int main(int argc, char *argv[])
{
    int a = 0; int b = 0;

    auto t1 = pplx::create_task([a] { return a+1; })
    .then([](int a) { throw std::runtime_error("a");
                      return a+1; });

    auto t2 = pplx::create_task([b] { return b+1; })
    .then([](int b) { throw std::runtime_error("b");
                      return b+1; });

    (t1 && t2)
    .then([] (std::vector<int>) { /*...*/ })
    .then([] (pplx::task<void> prev) {
        try {
            prev.get();
        } catch (std::runtime_error e) {
            std::cout << "caught " << e.what() << std::endl;
        }
    });

    std::cin.get();
}

try/catch 能够捕获两个异常中先发生的一个。我怎样才能捕获另一个？

Answer 1

您必须向每个子任务添加最终的基于任务的延续。我建议重新抛出您捕获的任何异常，但是，这可能是一个坏主意，因为延续任务没有意识到这两个异常是等效的，请参阅下面的示例以获取证明。
输出:
抓到了
捕获最后一个
抓到了

此外，如果您删除 sleep ，您将收到“跟踪/断点陷阱”异常。

#include <pplx/pplxtasks.h>
#include <iostream>

int main(int argc, char *argv[])
{
    int a = 0; int b = 2;

    auto t1 = pplx::create_task([a] { return a+1; })
    .then([](int a) { throw std::runtime_error("a"); return a+1; })
    .then([] (pplx::task<int> prev)
    {
        int retVal = -1;
        try
        {
            retVal = prev.get();
        }
        catch (std::runtime_error e)
        {
            std::cout << "caught " << e.what() << std::endl;
            throw e;
        }

        return retVal;
    });

    auto t2 = pplx::create_task([b] { return b+1; })
    .then([](int b) { throw std::runtime_error("b"); return b+1; })
    .then([] (pplx::task<int> prev)
    {
        int retVal = -1;
        try
        {
            sleep(1);
            retVal = prev.get();
        }
        catch (std::runtime_error e)
        {
            std::cout << "caught " << e.what() << std::endl;
            throw e;
        }

        return retVal;
    });

    (t1 && t2)
    .then([] (std::vector<int> v) { for(int i : v) { std::cout << i << std::endl; } })
    .then([] (pplx::task<void> prev)
    {
        try
        {
            prev.get();
        }
        catch (std::runtime_error e)
        {
            std::cout << "caught final " << e.what() << std::endl;
        }
    }).get();
}