Programation parallèle MPMD

Bonjour,

Il est prévu en C++ des extensions OpenMP permettant l'optimisation par des tâches parallélisées.

Code:

1
2
3
double res{};
for [[omp::parallel()]] (int i=0; i<v.size(); ++i) res += v[i];
return res;

Si tu as déjà des traitements parallélisables, le plus simple - selon moi - est le multithreading.
En utilisant les std::async() par exemple :

Code:

1
2
3
4
5
6
7
8
9
10
11
double sommerAvecParallelisation( std::vector<double> const& v ) {
    const int N = v.size() / 4;
 
    std::future<double> fut1 = std::async( std::launch::async , [&] { return std::accumulate( v.cbegin() , v.cbegin() + N , 0. ); } );
    std::future<double> fut2 = std::async( std::launch::async , [&] { return std::accumulate( v.cbegin() + N , v.cbegin() + N*2 , 0. ); } );
    std::future<double> fut3 = std::async( std::launch::async , [&] { return std::accumulate( v.cbegin() + N*2 , v.cbegin() + N*3 , 0. ); } );
    double r4 = std::accumulate( v.cbegin() + N*3 , v.cend() , 0. );
 
    fut1.wait(); fut2.wait(); fut3.wait(); // attendre la fin des 3 traitements parralèles
    return fut1.get() + fut2.get() + fut3.get() + r4; // et cumuler les 4 sous-résultats
}