MPI - Broadcast/Raccoglitore asincrono

Question

Ho un progetto che richiede il numero "n" di processi per funzionare finché il problema non viene risolto. Ogni processo slave esegue lo stesso codice. Quando si verifica una determinata condizione, il processo deve notificare tutti gli altri processi in modo non bloccante. Anche gli altri processi devono ricevere questo messaggio in modo non bloccante.

C'è un modo per fare senza inserire un ciclo separato?

Answer 1

È da un po 'che non uso MPI. Ma le funzioni I non sono bloccanti. Forse qualcosa di simile:

int comm_size = comm.Get_size(); 
int comm_rank = comm.Get_rank(); 

int* data = new int[comm_size]; 

while (some_condition) 
{ 
    //During each iteration, check for messages from other nodes 
    for (int node = 0; node < comm_size; node++) 
    { 
     if (node != comm_rank) 
     { 
      if (comm.Iprobe(node, TAG_NUM)) 
      { 
       comm.Irecv(data[node], 1, MPI_INT, node, TAG_NUM); 
      } 
     } 
    } 

    if (some_other_condition) 
    { 
     //Send the message to every node 
     for (int node = 0; node < comm_size; node++) 
     { 
      if (node != comm_rank) 
      { 
       comm.Isend(data[node], 1, MPI_INT, node, TAG_NUM); 
      } 
     } 
    } 

    //do normal work here. 
} 

delete [] data;