Elegante manejo de excepción en OpenMP

Question

OpenMP prohíbe el código que deja el bloque de openmp por excepción. Por lo tanto, estoy buscando una buena manera de obtener las excepciones de un bloque openmp con el propósito de volver a lanzarlo en el hilo principal y manejarlo en un momento posterior. Hasta ahora el mejor que he podido para llegar a es el siguiente:

class ThreadException { 
    std::exception_ptr Ptr; 
    std::mutex   Lock; 
public: 
    ThreadException(): Ptr(nullptr) {} 
    ~ThreadException(){ this->Rethrow(); } 
    void Rethrow(){ 
     if(this->Ptr) std::rethrow_exception(this->Ptr); 
    } 
    void CaptureException() { 
     std::unique_lock<std::mutex> guard(this->Lock); 
     this->Ptr = std::current_exception(); 
    } 
}; 
//... 
ThreadException except; 
#pragma omp parallel 
{ 
    try { 
     //some possibly throwing code 
    } 
    catch(...) { except.CaptureException(); } 
} 

Aunque esto funciona muy bien, Regeneración de las posibles excepciones de la sección paralela, tan pronto como el objeto ThreadException se destruye, esta construcción sigue siendo una Es un poco difícil de usar al colocar un try {}catch(...){} alrededor de cada sección y tener que capturar manualmente la excepción.

Así que mi pregunta es: ¿Alguien sabe de una manera más elegante (menos detallada) para hacer esto (y si es así, cómo se ve)?

Answer 1

Puede utilizar algunas herramientas C++ 11 para limpiar un poco la sintaxis. Añadir esta función de miembro variadic a su clase ThreadException:

class ThreadException { 

    // ... 

    template <typename Function, typename... Parameters> 
    void Run(Function f, Parameters... params) 
    { 
     try 
     { 
      f(params...); 
     } 
     catch (...) 
     { 
      CaptureException(); 
     } 
    } 
}; 

A continuación, al llamar dentro de un constructo OpenMP utilizar una función lambda, así:

ThreadException e; 

#pragma omp parallel for 
for (int i = 0; i < n; i++) 
{ 
    e.Run([=]{ 
     // code that might throw 
     // ... 
    }); 
} 
e.Rethrow()