MPI - 流程的逻辑循环

Question

我正在构建一个简单的应用程序，它在三个迭代中构建一个逻辑循环，然后打印结果。首先，我使用阻塞发送和接收，从进程 0，我使用发送和接收，直到最后的 n-1 个进程，它发送到进程 0。在进程 0 中，我在 main 中有这段代码：

int i;
  MPI_Status status;
  MPI_Init(&argc, &argv);
  MPI_Comm_size(MPI_COMM_WORLD,&numtasks);
  MPI_Comm_rank(MPI_COMM_WORLD;&myrank);



if(myrank==0){


    for(i=0;i<3;i++){
      MPI_Send(msg,MPI_CHAR,myrank+1,99,MPI_COMM_WORLD);
      MPI_Recv(msg,100,MPI_CHAR, numtasks-1,99,MPI_COMM_WORLD,&status);
      printf("hello");
    }
  }
  else if(myrank==(numtasks-1)){
     MPI_Recv(msg,100,MPI_CHAR,numtasks-2,99,MPI_COMM_WORLD,&status);
     MPI_Send(msg,100,MPI_CHAR,0,99,MPI_COMM_WORLD);

  }
  else{
     MPI_Recv(msg,100,MPI_CHAR,myrank-1,99,MPI_COMM_WORLD,&status);
     MPI_Send(msg,100,MPI_CHAR,myrank+1,99,MPI_COMM_WORLD);
  }

我现在正在尝试获得 3 个结果，对吗？但我仍然只得到一个。其余代码很简单，对于 0 以外的进程，它们从 myrank-1 接收（myrank 是实际进程的数量）并发送到 rank+1 ......我还是不明白......谢谢你的想法。

Answer 1

MPI_Send可以选择等待接收方调用MPI_Recv。因此，如果您的所有进程都从调用MPI_Send 开始，它们都会挂起。尝试改用MPI_Isend，然后检查是否已使用MPI_Waitall 收到每条消息。

编辑：我不知道我是如何设法忽略第一个if 块中有一个循环的事实... *尴尬*。我想我过于关注 MPI 部分。尝试运行代码没有循环（但循环体仍然存在）；那么它应该按预期工作（例如，n = 3 个进程）：

1. 0 发送到 1 并等待从 2 接收
2. 1从0接收，发送到2，退出
3. 2从1接收，发送到0，退出
4. 0 从 2 接收，打印消息，然后退出

现在，再次重新插入循环。完全相同的事情将会发生，除了进程 0 将在第 4 步之后继续，并将发送到进程 1，它已经退出。尝试在else if 和else 块中也插入循环，或者从if 块中删除循环并将整个if / else if / else 包装在一个循环中。