如何有效地使用boost mpi广播功能?
How to use boost mpi broadcast function in an efficient way?
我正在尝试从根进程广播一个值并在所有其他进程中接收它。我用以下两种格式实现了它。
1.我在所有进程(root和所有其他slaves)中使用了广播功能
#include <boost/mpi.hpp>
#include <iostream>
#include <boost/serialization/string.hpp>
namespace mpi = boost::mpi;
int main(int argc, char* argv[])
{
mpi::environment env(argc, argv);
mpi::communicator world;
std::string value;
if (world.rank() == 0) {
value = "Hello, World!";
}
broadcast(world, value, 0);
std::cout << "Process #" << world.rank() << " says " << value << std::endl;
return 0;
}
2。我只从 root 调用广播,而从其他进程调用接收,如下所示:
if (world.rank() == 0) {
value = "Hello, World!";
broadcast(world, value, 0);
}
else {
world.recv(boost::mpi::any_source, boost::mpi::any_tag, value);
}
在这些示例中两者的工作方式似乎相似,但我想知道这里在代码效率和性能方面是否有任何偏好。
谢谢!
使用普通的broadcast
.
第二个版本不是正确的 MPI 程序。如果它有效,那只是偶然。通常 broadcast
和其他集合体都经过高度优化,可以利用系统拓扑信息。因此,它们比您自己使用点对点消息实现它的性能要好。它们还以更抽象的方式表达您的通信结构,从而产生更清晰的代码。
我正在尝试从根进程广播一个值并在所有其他进程中接收它。我用以下两种格式实现了它。 1.我在所有进程(root和所有其他slaves)中使用了广播功能
#include <boost/mpi.hpp>
#include <iostream>
#include <boost/serialization/string.hpp>
namespace mpi = boost::mpi;
int main(int argc, char* argv[])
{
mpi::environment env(argc, argv);
mpi::communicator world;
std::string value;
if (world.rank() == 0) {
value = "Hello, World!";
}
broadcast(world, value, 0);
std::cout << "Process #" << world.rank() << " says " << value << std::endl;
return 0;
}
2。我只从 root 调用广播,而从其他进程调用接收,如下所示:
if (world.rank() == 0) {
value = "Hello, World!";
broadcast(world, value, 0);
}
else {
world.recv(boost::mpi::any_source, boost::mpi::any_tag, value);
}
在这些示例中两者的工作方式似乎相似,但我想知道这里在代码效率和性能方面是否有任何偏好。
谢谢!
使用普通的broadcast
.
第二个版本不是正确的 MPI 程序。如果它有效,那只是偶然。通常 broadcast
和其他集合体都经过高度优化,可以利用系统拓扑信息。因此,它们比您自己使用点对点消息实现它的性能要好。它们还以更抽象的方式表达您的通信结构,从而产生更清晰的代码。