【发布时间】:2011-08-22 03:59:05
【问题描述】:
我正在尝试做一些 MPI,这是一个使用 MPI_Send、MPI_Recv(是的,阻塞)的简单程序。 Rank 0 向所有其他进程发送消息,其他进程接收它。但是,我的 MPI_Send 永远不会返回。我在这里错过了什么吗?谢谢!
#include<stdio.h>
#include<string.h>
#include<unistd.h>
#include"mpi.h"
int main(int argc, char **argv)
{
int rank, size, i;
MPI_Status status;
char message[20];
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
strcpy(message, "Hello, world");
if (rank==0){
for(i=1;i<size;i++){
printf("I am sending %s\n", message);
MPI_Send(message, 23, MPI_BYTE, 0, 7, MPI_COMM_WORLD);
printf("Sending node=%d, message=%s\n", rank, message);
}
}
else{
MPI_Recv(message, 23, MPI_BYTE, MPI_ANY_SOURCE, 7, MPI_COMM_WORLD,&status);
printf("Receiving node=%d, message=%s\n", rank, message);
}
MPI_Finalize();
return 0;
}
【问题讨论】: