MPI with C: 通信时间
MPI with C: Communication time
我刚开始学习 MPI,这是我的第一个在两个处理器之间发送和接收数据的程序...
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
MPI_Comm_size(MPI_COMM_WORLD,&size);
printf("Comm Size %d",size);
printf("Rank %d",rank);
if (rank == 0)
{
for(j=1;j<size;j++);
{
tmp = clock();
start_time = clock();
MPI_Send(&N,1,MPI_INT,j,j,MPI_COMM_WORLD);
MPI_Recv(&N,1,MPI_INT,j,j,MPI_COMM_WORLD,&status);
end_time = clock();
timer_overhead = start_time - tmp;
total_time = end_time - start_time - timer_overhead;
communication_time = total_time / 2;
printf("%d",total_time);
}
}
else
{
MPI_Recv(&N,1,MPI_INT,0,rank,MPI_COMM_WORLD,&status);
MPI_Send(&N,1,MPI_INT,0,rank,MPI_COMM_WORLD);
}
MPI_Finalize();
}
~
但是这个程序一直挂起,有人可以帮忙吗。
在你有 for 循环的那一行你放了';'最后。
for(j=1;j<size;j++);
删除“;”。
我刚开始学习 MPI,这是我的第一个在两个处理器之间发送和接收数据的程序...
MPI_Status status;
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
MPI_Comm_size(MPI_COMM_WORLD,&size);
printf("Comm Size %d",size);
printf("Rank %d",rank);
if (rank == 0)
{
for(j=1;j<size;j++);
{
tmp = clock();
start_time = clock();
MPI_Send(&N,1,MPI_INT,j,j,MPI_COMM_WORLD);
MPI_Recv(&N,1,MPI_INT,j,j,MPI_COMM_WORLD,&status);
end_time = clock();
timer_overhead = start_time - tmp;
total_time = end_time - start_time - timer_overhead;
communication_time = total_time / 2;
printf("%d",total_time);
}
}
else
{
MPI_Recv(&N,1,MPI_INT,0,rank,MPI_COMM_WORLD,&status);
MPI_Send(&N,1,MPI_INT,0,rank,MPI_COMM_WORLD);
}
MPI_Finalize();
}
~
但是这个程序一直挂起,有人可以帮忙吗。
在你有 for 循环的那一行你放了';'最后。
for(j=1;j<size;j++);
删除“;”。