Discussion :

[vincent tariel]

Bonjour tout le monde,
Dans une librairie, j'ai besoin d'avoir plusieurs receveurs qui sont en attente d'un message en même temps. Je me suis dit que la solution était d'inclure l'appel de recv dans des threads. Cependant, j'ai un comportement erratique à l’exécution avec des segmentations faults.
Voici le code servant de test à cette idée :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
mpi::communicator world;
int receiveInt()
{
    while(1==1){
        int i;
        world.recv(0,0,i);
        cout<<"int "<<i<<endl;
    }
}
int receiveStr()
{
    while(1==1){
        string str;
        world.recv(0,1,str);
        cout<<"str "<<str<<endl;
    }
}
int main(int argc, char* argv[]) 
{
    mpi::environment env(argc, argv);
    if (world.rank() == 0) {
        int i=0;
        while(1==1)
        {
            i++;
            sleep(1);
            world.send(1,0,i);
            string str = "Hello world!";
            world.send(1,1,str);
            i++;
        }
    }
    else
    {
 
        boost::thread thrd1(receiveInt);
        boost::thread thrd2 (receiveStr);
        thrd2.join();
        thrd1.join();
    }
}

Si quelqu'un pouvait m'aider, cela me rendrait une fière chandelle.
Merci

[vincent tariel]

Après des recherches, il faut ajouter [URL="http://omgili.com/mailinglist/boost-users/lists/boost/org/2010120605580817666web003roc2bluetiecom.html"]

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
 
    MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE , &provided);
    if (MPI_THREAD_MULTIPLE  > provided) {
        cerr<<"warning: MPI impl does not support the requested threading model"<<endl;
    }

Le problème est que maintenant j'ai le message d'erreur. Pour information, j'ai une distribution ubuntu.

[Joel F]

en general on fait des threads dans MPI, pas de MPI dans des threads.
Si tu veux des i/o asynchrone, regarde du cote de MPI_IRecv ...