下面的代码使用2n CPU计算1到1000的总和。每个处理器计算这个聚合的一部分,并独立地显示输出。
所有处理器计算的最终结果由第一个处理器收集并进行聚合,最后的结果显示在输出中。
#include <iostream>
#include <stdio.h>
#include <mpi.h>
static int MyNode, Nodes;
using namespace std;
int main(int* argc, char** argv[])
{
MPI_Init(argc, argv);
MyNode = MPI_Comm_rank(MPI_COMM_WORLD, &MyNode);
Nodes = MPI_Comm_size(MPI_COMM_WORLD, &Nodes);
MPI_Status status;
int sum = 0;
int accum = 0;
int FIndex = 1000 * MyNode / Nodes + 1;
int LIndex = 1000 * (MyNode + 1) /
Nodes;
for (int I = FIndex; I <= LIndex; I = I + 1)
sum += I;
if (MyNode != 0)
MPI_Send(&sum, 1, MPI_INT, 0, 1,
MPI_COMM_WORLD);
else
for (int J = 1; J < Nodes; J = J + 1) {
MPI_Recv(&accum, 1, MPI_INT,
J, 1, MPI_COMM_WORLD,
&status);
sum += accum;
}
if (MyNode == 0) {
cout << "Total Nodes is " << Nodes << ".The sum from 1 to 1000 is: " << sum << endl;
}
MPI_Finalize();
return 0;
}运行后,我遇到一个问题:Integer division by zero. (MyNode /Node)
为什么MyNode,Nodes是零?
发布于 2018-05-21 10:21:56
只需传递对MyNode和Nodes的引用
MPI_Comm_rank(MPI_COMM_WORLD, &MyNode);
MPI_Comm_size(MPI_COMM_WORLD, &Nodes);MPI_Comm_size在成功时返回MPI_SUCCESS。否则,返回值是错误代码。
发布于 2018-05-21 10:18:13
以下函数返回错误(如果有的话)
MyNode = MPI_Comm_rank(MPI_COMM_WORLD, &MyNode);
Nodes = MPI_Comm_size(MPI_COMM_WORLD, &Nodes);由于您将错误状态存储在MyNode和节点中,因此(在本例中没有错误),MyNOde和节点的值为0。
把它改成这个
int err;
err = MPI_Comm_rank(MPI_COMM_WORLD, &MyNode);
err = MPI_Comm_size(MPI_COMM_WORLD, &Nodes);https://stackoverflow.com/questions/50446599
复制相似问题