3

我正在尝试使用任务的&& 运算符加入两个 pplx 任务，其中两个子任务都可能引发异常。

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

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

#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 能够捕获首先发生的两个异常中的任何一个。我怎样才能抓住另一个？

4

1 回答 1

2

您必须为每个子任务添加一个最终的基于任务的延续。我建议重新抛出您捕获的任何异常，但是，这可能不是一个好主意，因为继续任务没有意识到这 2 个异常是等效的，请参见下面的示例以获取证明。
输出：
捕获 a
捕获的 final a
捕获的 b

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

#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();
}
于 2017-01-31T06:55:33.660 回答