我在使用Isend和Ireceive时遇到问题。我正在尝试向所有其他处理器发送消息,然后从其他处理器接收相同类型的消息,这些消息植入了相同的Isend方法。

void msgs(int my_rank, int num_procs){
    int arrive_count = 1;
    int leave_count = 0;
    int i;
    bool b_req = true;
    MPI_Request req, req2;
    //Send to all other procs
    for(i=0; i<num_procs; i++){
        if(i != my_rank){
            MPI_Isend(&b_req,sizeof(bool),MPI_BYTE,i,1,MPI_COMM_WORLD, &req);
        }
    }
    bool c_req;
    //Receive msgs from all other procs
    while(arrive_count != num_procs){
        for(i=0; i<num_procs; i++){
            if(i != my_rank){
                MPI_Irecv(&c_req,sizeof(bool),MPI_BYTE,i,1,MPI_COMM_WORLD, &req2);
                if(c_req){
                    c_req = false;
                    arrive_count ++;
                }
                MPI_Request_free(&req2);
            }
        }
    }
    printf("Done from rank: %d \n", my_rank);
}

最佳答案

您的代码段至少存在三个问题:


您不能将MPI_BYTEbool一起使用。 MPI标准允许您将MPI_C_BOOL_Bool一起使用,另一个选择是在传输bool之前在byteMPI_BYTE之间手动转换
您没有正确使用MPI_Isend()MPI_Recv()。您应该有一个请求数组,最后调用MPI_Waitall()
您可以在第一个循环中MPI_Irecv()所有远程对等方,然后在MPI_Test()中查看消息是否已在另一个循环中到达(请注意,您将需要一个c_req数组),或者只有一个循环消息到达后紧跟MPI_Iprobe()MPI_Recv()(并且需要一个c_req


附带说明一下,除非您在while循环中进行任何处理,否则您可能需要考虑集体操作,例如MPI_Alltoall()

10-02 04:19