Comment attraper des exceptions de plusieurs tâches à Casablanca

Question

J'essaie de joindre deux tâches pplx en utilisant la tâche && operator, où les deux sous-tâches peuvent lancer des exceptions.

Je comprends du ppl documentation que je peux attraper une exception dans une continuation finale basée sur les tâches. Cela fonctionne également à Casablanca. Cependant, je ne peux attraper qu'une seule exception dans ma suite finale. Si les deux sous-tâches sont lancées, l'une reste non gérée.

Voici un exemple minimal illustrant mon problème:

#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(); 
} 

Le try/catch est en mesure de rattraper celui des deux exceptions se produit d'abord. Comment puis-je attraper l'autre?

Answer 1

Vous devez ajouter une suite finale basée sur les tâches à chaque sous-tâche. Je suggère de relancer toute exception que vous attrapez, cependant, ce serait probablement une mauvaise idée puisque la tâche de continuation ne réalise pas que les 2 exceptions sont équivalentes voir ci-dessous l'exemple pour la preuve.
Sortie:
attrapé un
pris en train finale un
pris b

En outre, si vous supprimez le sommeil, vous recevrez une exception "piège Trace/point d'arrêt".

#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(); 
}