MPI - Transmisión asíncrona/Reúna

Question

Tengo un proyecto que requiere 'n' cantidad de procesos para que funcione hasta que se solucione el problema. Cada proceso esclavo ejecuta el mismo código. Cuando surge una determinada condición, el proceso debe notificar a todos los otros procesos de forma no bloqueante. Los otros procesos también necesitan recibir este mensaje de forma no bloqueante.

¿Hay alguna manera de hacerlo sin enhebrar un bucle separado?

Answer 1

Ha pasado un tiempo desde que utilicé MPI. Pero las funciones I no bloquean. Tal vez algo como esto:

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;