Définir le nombre de threads à l'aide de omp_set_num_threads() à 2, mais omp_get_num_threads() renvoie 1

J'ai la suite de code C/C++ en utilisant OpenMP:

    int nProcessors=omp_get_max_threads();
    if(argv[4]!=NULL){
        printf("argv[4]: %s\n",argv[4]);
        nProcessors=atoi(argv[4]);
        printf("nProcessors: %d\n",nProcessors);
    }
    omp_set_num_threads(nProcessors);
    printf("omp_get_num_threads(): %d\n",omp_get_num_threads());
    exit(0);

Comme vous pouvez le voir, je suis en train de définir le nombre de processeurs à utiliser basée sur un argument transmis sur la ligne de commande.

Cependant, j'obtiens le résultat suivant:

argv[4]: 2   //OK
nProcessors: 2   //OK
omp_get_num_threads(): 1   //WTF?!

Pourquoi n'est-ce pas omp_get_num_threads() retour 2?!!!

Comme cela a été souligné, je vais appeler omp_get_num_threads() dans une série de région, d'où la fonction renvoie 1.

Cependant, j'ai le texte suivant du code en parallèle:

#pragma omp parallel for private(i,j,tid,_hash) firstprivate(firstTime) reduction(+:nChunksDetected)
    for(i=0;i<fileLen-CHUNKSIZE;i++){
        tid=omp_get_thread_num();
        printf("%d\n",tid);
        int nThreads=omp_get_num_threads();
        printf("%d\n",nThreads);
...

sorties:

0   //tid
1   //nThreads - this should be 2!
0
1
0
1
0
1
...
  • Faites-vous appel à ce à partir d'une série qui fait partie de votre programme? Si oui, le nombre de threads est en fait 1.
  • Il stephan - merci beaucoup pour le comprendre. J'ai édité l'OP avec une autre question connexe.
  • Si vous utilisez Intel IPP bibliothèques avec OpenMP activé, j'ai vu des cas dans lesquels ils entrent en collision...
  • C'est intéressant. Je suis à l'aide d'Intel fil blocs de construction...
InformationsquelleAutor Eamorr | 2012-01-23
  1. 31

    La omp_get_num_threads() appel retourne 1 dans la série section de code. Voir Lien

    Si vous avez besoin d'avoir de code parallèle pour obtenir la valeur correcte, voici comment votre code devrait ressembler à:

    #include <iostream>
#include <omp.h>

int main (int argc, const char * argv[])
{
    int nProcessors = omp_get_max_threads();

    std::cout<<nProcessors<<std::endl;

    omp_set_num_threads(nProcessors);

    std::cout<<omp_get_num_threads()<<std::endl;

#pragma omp parallel for 
    for(int i = 0; i < 5; i++){
        int tid = omp_get_thread_num();
        std::cout<<tid<<"\t tid"<<std::endl;
        int nThreads = omp_get_num_threads();
        std::cout<<nThreads<<"\t nThreads"<<std::endl;
    }

    exit(0);
}

    Ce code produit:

    2

    1
0    tid
2    nThreads
0    tid
2    nThreads
0    tid
2    nThreads
1    tid
2    nThreads
1    tid
2    nThreads

    Il semble que vous avez ouvert mp pas activé ou votre boucle n'est pas dans la forme qui peut être parallized par openmp

    • OK, mais quand je vais dans une région parallèle, c'est encore de retour 1... s'il vous Plaît voir mon edit. Merci beaucoup...
    • Où en êtes-vous de commencer votre région parallèle, je ne vois pas dans l'édition.
    • Désolé, je viens de mettre à jour maintenant...
    • Merci, avez-vous changer la variable i ou fileLen à l'intérieur de votre région parallèle? Comme il se peut que vos de boucle ne peut pas être parallised par openmp, en raison des effets secondaires.
    • Pas - ne pas modifier ces variables
    • J'ai édité mon code ci-dessus et cela fonctionne pour moi, s'il vous plaît montrer un certain exemple, où votre code génère cette erreur.
    • Hey, merci pour ça. Il s'avère que j'ai besoin de passer-fopenmp à LIBS et CXXFLAGS dans mon Makefile... ;(

    InformationsquelleAutor tune2fs
  2. 9

    vous utilisez la mauvaise fonction. utilisation omp_get_max_threads pour vérifier le nombre maximum de threads.

    InformationsquelleAutor Bort
  3. 0

    Il a été déjà souligné que omp_get_num_threads() retourne 1 dans les sections séquentielles du code. En conséquence, même si le réglage, par omp_set_num_threads(), un nombre de threads de plus de 1, tout appel à omp_get_num_threads() sera de retour 1, à moins que nous sommes dans une section parallèle. L'exemple ci-dessous tente de clarifier ce point

    #include <stdio.h>

#include <omp.h>

int main() {

    const int maxNumThreads = omp_get_max_threads();

    printf("Maximum number of threads for this machine: %i\n", maxNumThreads);

    printf("Not yet started a parallel Section: the number of threads is %i\n", omp_get_num_threads());

    printf("Setting the maximum number of threads...\n");
    omp_set_num_threads(maxNumThreads);

    printf("Once again, not yet started a parallel Section: the number of threads is still %i\n", omp_get_num_threads());

    printf("Starting a parallel Section...\n");

#pragma omp parallel for 
    for (int i = 0; i < maxNumThreads; i++) {
        int tid = omp_get_thread_num();
        printf("This is thread %i announcing that the number of launched threads is %i\n", tid, omp_get_num_threads());
    }

}
    InformationsquelleAutor JackOLantern