Reduce和Broadcast在MPI中的应用
在MPI中，Reduce和Broadcast是两种常用的通信操作。
- Reduce：
- 概念：Reduce是一种聚合操作，用于将多个进程的数据合并为一个结果。通常，Reduce操作会在一个或多个进程中执行，并将结果发送到指定的进程。
- 分类：Reduce操作可以分为全局Reduce和局部Reduce。全局Reduce会将所有进程的数据合并为一个结果，而局部Reduce仅将指定进程的数据进行合并。
- 优势：Reduce操作可以方便地在MPI应用程序中实现全局数据的统计、求和、取最大/最小值等聚合操作，有助于减少通信量和提高计算效率。
- 应用场景：Reduce操作常用于并行计算中需要全局统计或全局合并结果的情况，例如并行排序、并行规约等。
- 腾讯云相关产品推荐：腾讯云提供了适用于高性能计算的Elastic MPI和云弹性计算服务（ECS），可满足MPI应用程序的运行需求。具体产品介绍请参考：腾讯云弹性计算服务和Elastic MPI。
- Broadcast：
- 概念：Broadcast是一种广播操作，用于将一个进程的数据传播到所有其他进程。在MPI中，一个进程会将数据发送给所有其他进程，使得每个进程都能获得相同的数据副本。
- 分类：Broadcast操作可以分为一对多的广播和多对多的广播。一对多的广播是指一个进程将数据发送给其他所有进程，而多对多的广播是指多个进程之间进行互相广播。
- 优势：Broadcast操作可以方便地将共享数据传递给所有进程，使得每个进程都具备相同的数据副本，简化了并行计算中的数据分发问题。
- 应用场景：Broadcast操作常用于并行计算中需要将共享数据传递给所有进程的情况，例如初始化共享参数、同步数据状态等。
- 腾讯云相关产品推荐：腾讯云提供了适用于高性能计算的Elastic MPI和云弹性计算服务（ECS），可满足MPI应用程序的运行需求。具体产品介绍请参考：腾讯云弹性计算服务和Elastic MPI。
注意：在回答中没有提及特定的云计算品牌商，如亚马逊AWS、Azure、阿里云等，因为题目要求不能提及这些品牌商。
相关·内容
1回答
我正在设计一个Python程序来计算某个固定值为n的k 我的目的是应用reduce和broadcast命令来并行处理所有处理器之间的工作。我是MPI的新手，不知道怎么做，所以我在代码中注释掉了这两行。我想知道在MPI中完成reduce和broadcast命令有没有什么特别的方向。我的原始代码是
import numpy as np
import platform
import sys
from mpi4py import MPI
comm = MPI.COMM_WORLD
id = comm.Get_rank( )
p = comm.Get_size( )
p=1
# Find
浏览 6提问于2019-03-12得票数 0
回答已采纳
我的MPI节目测量广播时间：
MPI_Barrier(MPI_COMM_WORLD);
total_mpi_bcast_time -= MPI_Wtime();
MPI_Bcast(data, num_elements, MPI_INT, 0, MPI_COMM_WORLD);
MPI_Barrier(MPI_COMM_WORLD);
total_mpi_bcast_time += MPI_Wtime();
我们需要MPI_Barrier等待所有进程完成其任务(同步) .But --实际上，MPI_Barrier是一个集体通信(所有进程都报告根进程以继续编程).And，因此我们测量的
浏览 6提问于2016-03-17得票数 1
回答已采纳
1回答
使用下面的代码，我将4个进程分割成列组，然后从对角线(0,3)在同一列中广播。进程0广播到2。3应该广播到1。但它不像预期的那样工作。有人能看到什么不对劲吗？
0 1
2 3
#include <stdio.h>
#include <stdlib.h>
#include <iostream>
#include <mpi.h>
#include <mpi.h>
using namespace std;
int main(int argc, char **argv){
浏览 2提问于2021-05-22得票数 2
回答已采纳
我正在尝试使用MPI_Comm_Spawn运行一个mpi程序。我生成了一个工作程序，然后在两个程序中调用MPI_reduce，以得到一些结果。由于某种原因，应用程序挂在MPI_Comm_spawn，然后在一分钟后中止。生成的进程只进入其代码段，在该代码段发生后调用MPI_reduce。然后应用程序继续挂起，然后在命令提示符中出现更多错误。应该发生的是，生成的程序和主程序都到达MPI_Reduce调用，主程序得到一个和，并输出该和。
这是输出，我把一个<>放在它的MPI输出，而不是我自己的输出
world size = 1
About to call MPI_Comm_spaw
浏览 5提问于2013-02-08得票数 1
回答已采纳
我正在开发一个使用MPI_Send()和MPI_Recv()来代替MPI_Reduce()的程序。
我得到所有要运行的东西，除了代码的最后一部分，它给出PI近似、错误和运行时。我也没有得到正确的和值后，收到。
我相信MPI_Recv()端出了问题，但我可能错了。在运行此程序时，我只使用两个处理器。当使用MPI_Reduce时，程序可以很好地工作，而不需要将PI初始化为值。
#include "mpi.h"
#include <stdio.h>
#include <math.h>
int main( int argc, char *argv[])
{
浏览 4提问于2021-02-04得票数 2
回答已采纳
1回答
我试图从根进程广播一个值，并在所有其他进程中接收它。我用以下两种格式实现了它。1.我在所有进程(根进程和所有其他从进程)中使用广播功能。
#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;
浏览 2提问于2016-06-02得票数 1
回答已采纳
我开发了这个简单的函数，用mpi在并行环境中执行n个数的和，使用的策略是每个处理器计算其部分和，然后在两两不同的处理器之间通信计算的数量，创建一个二叉树。当然，如果处理器的数量是2^n的倍数，则可以应用此策略。
参数: menum = id处理器，nproc =处理器总数，sum =部分和
void Second_Strategy( int menum ,int nproc,int sum, MPI_Status status)
{
int a,b,p,i,sumtmp;
double t_tot, t1, t2, diff;
p=log(nproc)/log
浏览 0提问于2012-10-29得票数 1
回答已采纳
1回答
我正在尝试使用集体MPI函数在生成的过程中获取值。
在这种情况下，我有一个N*N矩阵，我希望将每一行传递给每个进程。获取每个进程中的值并对其值进行求和。
我用这个例子：
main
int main(int argc, char *argv[]){
int *n, range, i, j, dato, resultado;
int *matriz;
char *nombre_esclave="esclavo";
//MPI Section
int rank, size;
MPI_Comm hijos;
MPI_Status status;
浏览 3提问于2017-01-31得票数 1
3回答
我正在开发一个可以将一个数组和一个矩阵相乘的小应用程序。它工作起来没有任何问题。我想测量应用程序的执行时间。我可以找到每个进程的单独执行时间(它的开始和结束)，但我需要全局时间。
这是我的代码：
int main(int argc, char **argv){
int rang, procesus;
MPI_Status statut;
double start, end, max_end = 0, min_start = 10000;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WOR
浏览 1提问于2011-03-14得票数 20
回答已采纳
我有两个程序。" master“产生执行一些计算的”worker“，我希望master从worker获取结果并存储和。我尝试使用MPI_Reduce从工人那里收集结果，工人使用MPI_Reduce将结果发送到主MPI_Comm。我不确定这是不是正确的。以下是我的程序：
师父：
#include <mpi.h>
#include <iostream>
using namespace std;
int main(int argc, char *argv[]) {
int world_size, universe_size, *universe_sizep
浏览 0提问于2013-02-06得票数 4
回答已采纳
当使用MPI_reduce时，根处理器是否也对自己应用指定的MPI操作？
例如，假设下面的代码由所有处理器运行，包括根，根是否会将它的local_sum减少到global_sum中，就好像它是非根的一样？
int local_sum;
int global_sum;
int i;
for (i = 0; i < 5; i++) {
local_sum += rand_nums[i];
}
MPI_Reduce(&local_sum, &global_sum, 1, MPI_INT, MPI_SUM, ROOT, MPI_COMM_WORLD);
浏览 2提问于2016-09-17得票数 1
1回答
Scala负载平衡和检索
、、、
我有一个很大的邻接矩阵，我想把工作分配给每个参与者，比如说100个索引。
有没有办法像我们在MPI中那样将工作负载分配给不同的参与者(使用MPI_Scatter() )
有没有办法像MPI (MPI_Broadcast/ MPI_Broadcast)那样减少/广播结果。
我能想到的一种粗鲁的方法是传递整个矩阵，然后将索引传递给每个参与者，但这将违背使用参与者的目的。此外，如果我真的喜欢这样，如果演员在远程位置也不是一个好主意。
任何建议都会有很大帮助。
谢谢
浏览 0提问于2014-04-14得票数 0
1回答
因为我已经学习了各种并行范式标准的基础知识，如OpenMP，MPI，OpenCL来编写并行编程。但我对Map-Reduce编程模型了解不多。
众所周知，各种流行的公司都在遵循Map-Reduce编程模型来解决其庞大的数据密集型任务。MPI是为大规模并行计算机和工作站集群上的高性能计算而设计的。
所以我的第一个困惑是..是否可以使用Map-Reduce模型代替MPI标准，反之亦然？或者这取决于应用程序！
它们之间的确切区别是什么？
Which one is better and when?
浏览 0提问于2012-02-24得票数 4
回答已采纳
2回答
我有邻接矩阵和以下代码：
if (is_broadcast_message) {
MPI_Send(&broadcast_message,1,MPI_INT,j,3,MPI_COMM_WORLD);
MPI_Send(&message,20,MPI_CHAR,j,3,MPI_COMM_WORLD);
}
Where broadcast_message=128(随机数，用于知道我何时收到，这是一条广播消息)
消息被定义为char20。
else if (i have to send only to a node) {
MPI_Send(&desti
浏览 5提问于2014-01-10得票数 5
我从MPI开始学习。我在MPI_Broadcast之后使用了一个MPI_Broadcast，其中我向所有进程广播了一个变量。但是当我打印广角的变量时，它是一些来自记忆的值，而不是来自广播的值。不知道我在哪里做错了。请给我任何建议。
void main(int argc, char *argv[]){
int x, comm_sz, my_rank;
MPI_Init(NULL,NULL);
MPI_Comm_size(MPI_COMM_WORLD, &comm_sz);
MPI_Comm_rank(MPI_COMM_WORLD, &my_rank);
i
浏览 5提问于2015-11-08得票数 0
回答已采纳
2回答
开放MPI广播时延测量
、、、、
从阅读文档来看，MPI_Bcast也是一个阻塞调用(因此boost：：mpi：：call )也是如此。测量根节点广播所需的时间是否很好地衡量了从根节点到所有其他节点获取数据所需的时间？
也就是说。
int64_t t1 = Utility::picosecondTime(); //exactly what it sounds like; utility that measures current time in picoseconds
boost::mpi::broadcast(communicator, variable, 0);
std::cout << "Broadc
浏览 0提问于2013-08-28得票数 2
回答已采纳
1回答
因此，我正在学习并行编程，并编写一个程序来计算一个数字列表的全局和。这个列表被分成几个子列表(取决于我有多少个核)，并且这些列表被单独地并行地相加。在每个核心都有自己的和之后，我使用MPI_Reduce将值发送回其他核心，直到它们最终返回根。我们不只是将它们的值直接发送回根(O(n))，而是将它们并行地发送回其他内核(O(log(N)，如下图所示：
所以，一切都很好直到54岁。我想我可能误解了MPI_Reduce。我的印象是，MPI_Reduce只是在一个线程中取一个值，在另一个线程(目标线程)中取一个值，然后对这个值执行一个操作，然后将它存储在第二个线程中的同一个位置。至少这是我想要的。我想
浏览 2提问于2014-01-24得票数 1
回答已采纳
1回答
我不太明白MPI_Reduce是如何与数组工作的。我需要做一个元素之和。
为了测试MPI_Reduce函数，我编写了这段简单的代码，它运行如下：
double a[4] = {0,1,2,(double)process_id};
double b[4];
MPI_Reduce(&a, &b, 4, MPI_DOUBLE, MPI_SUM, p-1, MPI_COMM_WORLD);
if(id == p-1) {
for(int i = 0; i < 4; i++){
printf("%f, ", b[i]);
}
}
它打
浏览 14提问于2021-02-27得票数 0
回答已采纳
1回答
在sum上创建优化的reduce
、、、、
我刚刚开始学习高性能计算的课程，正在做一项任务，我们希望在MPI_SUM上实现相当于MPI_Reduce的Reduce功能……很简单，对吧？下面是我所做的：
我从从所有节点向根节点发送数据/数组的基本概念开始(第0级进程)，在那里我计算了总和。
作为第二步，我进一步优化了它，以便每个进程将数据发送到它的镜像，由镜像计算和，这个过程不断重复，直到结果最终出现在根节点(第0个进程)。我的实现如下：
for(k=(size-1); k>0; k/=2)
{
if(rank<=k)
{
if(rank<=(k/2
浏览 0提问于2018-03-25得票数 3
我正在尝试使用mpi4py执行以下代码：
from mpi4py import MPI
import numpy
comm = MPI.COMM_WORLD
size = comm.Get_size()
rank = comm.Get_rank()
inp = numpy.random.rand(size)
senddata = inp[rank]
recvdata=comm.reduce(senddata,None,root=0,op=MPI.MINLOC)
print 'on task',rank,'reduce: ',senddata,recvd
浏览 0提问于2016-10-29得票数 0
假设我有n个过程：
他们进行计算，然后将结果发送到0。这就是我想要发生的：
级别0将等待，直到它从所有级别得到结果，然后将它们添加到中。
我该怎么做？此外，我还想避免下列情况：
就像。4进程P0，P1，P2，P3，
P1 -> P0
P2 -> P0
P3 -> P0
同时，P1已经完成了计算，因此P1->P0再次发生。
，我希望P0只在一个周期中对3个进程进行添加，然后再对下一个进行添加。
有人能建议MPI功能来做这件事吗？我知道MPI_Gather的事，但我不确定它是否阻塞
我想到了这个：
#include <mpi.h>
#include <st
浏览 2提问于2017-04-14得票数 1
回答已采纳
2回答
我试图计算使用MPI_Bcast和通常的MPI_send和MPI_Recv向所有进程广播100万个整数的速度和效率之间的差异。但我不明白为什么我会得到这个分割错误，任何帮助都会非常感谢。这是我的代码：
#define num_of_ints 1000000
int *create_random_array(int);
int main(int argc, char *argv[]){
int size=0, my_rank =0, i=0;
int tag =99;
double start, end;
int *array = NULL;
srand(time(NULL));
MPI_St
浏览 0提问于2014-04-16得票数 1
回答已采纳
1回答
我计算了一些和，并且我需要找到这些和中的最小值。我可以串行执行，但我很难使用mpi将其并行化。我按顺序计算特定的和，并找到最小值：
for(i = 0; i < size; i++){
for(j = 0; j < size; j++){
for(k = 0; k < size; k+=gap){
for(m = 0; m < size; m+=gap){
c1 = calculation1(i,j,k,m);
if(c1 > cutoff){
浏览 0提问于2012-02-20得票数 0
回答已采纳
1回答
我在使用boost.mpi库进行自定义减操作编译时遇到了困难。我正在尝试从元素上添加两个std::vector。当我使用将两个向量相加在一起时，这个操作工作得很好，但是当我尝试使用mpi::reduce时，我得到了一个错误：“对于第一个参数，从'int‘到'const：：vectors’之间没有已知的转换。”
#include <boost/mpi.hpp>
namespace mpi = boost::mpi;
template <typename T>
struct elementwise_add {
std::vector<T&g
浏览 3提问于2015-03-04得票数 4
回答已采纳
我有一个非常简单的MPI程序来测试MPI_Reduce的行为。我的目标很简单：
~让每个进程创建一个随机数(范围为1-100)，然后使用mpirun -np 5 <program_name_here>运行程序。
有进程0，找到所有5个数字的和
有过程1，找到所有5个数字的乘积。
有过程2，找到所有5个数字的最大值。
有过程3，找到所有5个数字的最小值
有进程4，按位查找所有5个数字的位数。
这是我的节目：
#include <stdio.h>
#include <stdlib.h>
#include <mpi.h>
#
浏览 6提问于2016-04-04得票数 2
回答已采纳
1回答
我在并行代码中遇到了一个问题，我需要将所有进程的值减少到根进程，对它们求和，然后将和赋给一个数组元素。我想在一个循环中这样做，这样每次MPI_Reduce()调用都简化为数组中的连续元素。我想知道如何指向数组中的特定位置。for循环代码的一部分如下所示。
for(int i = 1; i < N_t; i++) {
....
loc_EK = valEK * (cblas_ddot(loc_N, loc_vx, 1, loc_vx, 1) +
cblas_ddot(loc_N, loc_vy, 1, loc_vy, 1));
loc_
浏览 0提问于2021-03-24得票数 1
因为MPI_Reduce和MPI_Barrier是开销很大的命令，所以我必须减少线程之间的一些通信。我知道MPI_Reduce和MPI_Barrier的主要工作。有时我观察到，MPI_Reduce在减少一个线程中的所有值的同时，也在做MPI_Barrier的工作。有没有可能，如果我必须使用mpi_Reduce，那么我可以跳过MPI_Barrier？
浏览 5提问于2020-01-13得票数 0
每当我试图以mpi_in_place作为发送缓冲区来调用mpi_reduce时，它就会崩溃。谷歌搜索发现这是Mac for OMPI1.3.3上的一个问题--但我在CentOS上使用的是OMPI1.6.3( gfortran 4.4.6)。
以下程序崩溃：
PROGRAM reduce
USE mpi
IMPLICIT NONE
REAL, DIMENSION(2, 3) :: buffer, gbuffer
INTEGER :: ierr, me_world
INTEGER :: buf_shape(2), counts
CALL mpi_init(ierr
浏览 0提问于2013-07-19得票数 13
回答已采纳
1回答
我正在尝试使用MPI库用c编写一个程序。在我的程序中，我正在解决TSP问题(但不是用任何特殊的算法……)。我的输入参数是int nCites、int xCoord[]和int yCoord[]。我将它们捆绑到Coordinates中，并使用MPI_Bcast使它们对所有线程都可用。
我的问题是:在我计算完每个线程中所有路径的权重后，我希望将它们简化为一个结果，即最好的结果。我尝试过使用MPI_Reduce，但是有些东西导致分段错误(只在一个线程中，通常是root)，这就是我感到困惑的地方。
这是主要的代码和结构：
typedef struct Coordinates_t {
int*
浏览 1提问于2011-01-20得票数 3
回答已采纳
1回答
只是一个问题。如果我使用函数MPI_Reduce，当这是一个动态数组时，只有根可以分配接收缓冲区。例如：
int r = 10;
int *yloc, *y;
...
yloc = calloc(r*sizeof(int)); // for all processes
if (I'm the master process) {
y = calloc(r*sizeof(int)) // inside the if-block ...
...
}
y = calloc(r*sizeof(int)) // ...or outside the if-block?
...
浏览 1提问于2016-01-15得票数 3
我已经在这上面花了几天的时间，搜索了很多东西(包括这个站点和Fortran文档)，所以如果这真的是一个非常简单的问题，请原谅我，但我在Fortran方面相对缺乏经验，并且来自C++/C#/Java背景。我使用的是F90的MPI编译器，所以我无法使用任何更新的功能，我对此没有选择。
我正在尝试包装MPI函数，以创建一个通信层和封装的直接MPI交互(只是无法动摇这些面向对象的习惯！)。为此，我需要向包装器函数传递数据，或者从包装器函数传递数据。
例如，具有以下原型：
INCLUDE ’mpif.h’
MPI_SEND(BUF, COUNT, DATATYPE, DEST, TAG, COMM, I
浏览 2提问于2015-03-10得票数 1
我在C++中有下面的代码片段，它基本上是使用经典的蒙特卡洛技术来计算圆周率。
srand48((unsigned)time(0) + my_rank);
for(int i = 0 ; i < part_points; i++)
{
double x = drand48();
double y = drand48();
if( (pow(x,2)+pow(y,2)) < 1){ ++count; }
}
MPI_Reduce(&count, &to
浏览 3提问于2012-02-15得票数 8
回答已采纳
1回答
我有一个巨大的代码和一个非常奇怪的MPI错误。MPI并行化非常简单，只需计算代码中某个位置的平均值，可以将其隔离为：
// Declaration
std::vector<double> local;
std::vector<double> global;
unsigned int size;
/* ... huge computations here ... */
size = 10000; // approximately
local.resize(size);
global.resize(size);
local.shrink_to_fit();
global.s
浏览 3提问于2014-06-24得票数 1
回答已采纳
我使用12个节点的windows集群(每个都有24个核心)来运行C++ MPI程序(使用Boost MPI)。一个运行与MPI减少，一个注释掉MPI减少(仅为速度测试)。运行时间分别为01:17:23和01:03:49。在我看来，MPI减少花费了很大一部分时间。我认为这可能是值得尝试首先减少在节点级别，然后减少到头节点，以提高性能。
下面的是一个用于测试目的的简单示例。假设有4个计算机节点，每个节点有2个核心。我想首先使用mpi来减少每个节点的开销。在此之后，减少到头节点。我不太熟悉mpi和下面的程序崩溃。
#include <iostream>
#include <boos
浏览 1提问于2019-07-01得票数 0
回答已采纳
我正在看这里的代码，我正在做的练习。
我对这里显示的部分感到困惑。
MPI::COMM_WORLD.Reduce(&mypi, &pi, 1, MPI::DOUBLE, MPI::SUM, 0);
if (rank == 0)
cout << "pi is approximately " << pi
<< ", Error is " << fabs(pi - PI25DT)
<< endl;
我的问题是，mpi reduce函数是否
浏览 1提问于2011-12-22得票数 1
回答已采纳
1回答
我试图在超立方体中广播一个充满1的向量，该向量来自process
int main(int argc, char **argv) {
int myRank, nProc;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &myRank);
MPI_Comm_size(MPI_COMM_WORLD, &nProc);
MPI_Request request;
MPI_Status status;
MPI_Barrier(MPI_COMM_WORLD);
double
浏览 1提问于2018-10-04得票数 1
回答已采纳
使用MPI，我们可以使用广播将数组发送到多个节点，或者使用reduce将多个节点的数组组合到一个节点上。
我猜实现这些的最快方法是使用二叉树，其中每个节点要么发送到两个节点(bcast)，要么减少两个节点(reduce)，这将给出节点数量的时间对数。
看起来没有任何理由让广播比reduce特别慢吧？
我在一个由4台计算机组成的集群上运行了下面的测试程序，其中每台计算机都有12个核心。奇怪的是，广播比reduce慢得多。为什么？有什么我能做的吗？
结果是：
inited mpi: 0.472943 seconds
N: 200000 1.52588MB
P = 48
did alloc: 0.0
浏览 6提问于2013-06-09得票数 1
我尝试将我的处理器分成组，然后独立地将每组的总和相加……但是直到现在我才找到正确的结果。下面是一个简单的例子：
int main(int argc, char** argv)
{
int size, rank,i=0,localsum1=0,globalsum1=0,localsum2=0,globalsum2=0;
MPI_Init(&argc,&argv);
MPI_Comm_size(MPI_COMM_WORLD,&size);
MPI_Comm_rank(MPI_COMM_WORLD,&rank);
if(r
浏览 2提问于2013-02-11得票数 5
编译器: gfortran-4.8.5
MPI库: OpenMPI-1.7.2 (预装OpenSuSE 13.2)
此程序：
use mpi
implicit none
real*16 :: x
integer :: ierr, irank, type16
call MPI_Init(ierr)
call MPI_Comm_Rank(MPI_Comm_World, irank, ierr)
if (irank+1==1) x = 2.1
if (irank+1==8) x = 2.8
if (irank+1==7) x = 5.2
if (ira
浏览 2提问于2015-10-14得票数 8
3回答
(初学者问题)我试图使用MPI_Comm_Spawn动态地产生进程，然后向子进程广播一条消息，但程序在从根进程到子进程的广播中停止了。我正在遵循来自的文档，但是我不能让它工作。有谁能帮帮我吗？
#include <stdio.h>
#include <mpi.h>
int main(int argc, char *argv[])
{
MPI_Init(&argc, &argv);
MPI_Comm parentcomm;
MPI_Comm_get_parent( &parentcomm );
if (pare
浏览 6提问于2012-04-02得票数 8
使用MPICH2库的CRAY超级计算机。每个节点有32个CPU。
我在N个不同的MPI级别上有一个浮点数，其中每个级别都位于不同的节点上。我需要在这组浮子上做一次减缩手术。我想知道一个MPI_Reduce是否比在根上计算约简的MPI_Gather更快，对于任意的N值，请假定对根秩的缩减将使用一个好的并行约简算法来完成，这个算法可以利用N个线程。
如果N的任何值都不是更快，那么对于较小的N，例如16，还是更大的N，它会是正确的吗？
如果是真的，为什么？(例如，MPI_Reduce是否会使用一种树通信模式，该模式会在与树的下一级通信的方法中隐藏缩减操作的时间？)
浏览 4提问于2018-04-25得票数 0
回答已采纳
我正在处理mpi代码，但我有一个关于标签的错误。我用的是MPI_ANY_tag。当我遇到这个错误时，我将标签替换为零，它根本没有产生任何东西。有人能告诉我原因吗？
#include<iostream>
#include<mpi.h>
using namespace std;
void ParaStochSimulator::first_reacsimulator()
{
if (mnprocess_id != 0)/*worker node*/
{
PrepareRun();
//SimulateSingleStep();
//PostProce
浏览 0提问于2016-11-07得票数 1
下面是我的代码：
#include "mpi.h"
#include <stdio.h>
#include <stdlib.h>
int main(int argc, char **argv)
{
int tmpv = 10, tmpvsum;
MPI_INIT(&argc, &argv);
printf("begin allreduce.");
MPI_REDUCE(&tmpv,&tmpvsum,1,MPI_INT,MPI_SUM,0,MPI_COMM_WORLD);
浏览 2提问于2015-03-24得票数 2
1回答
我正在为一个并行计算类编写MPI程序。我已经让代码正常工作了，并且输出了正确的结果，但是当我尝试用多个进程调用MPI_Finalize时，我得到了一个Buss错误。我在OS上通过Eclipse中的PTP环境运行它。错误如下：
[Fruity:49034] *** Process received signal ***
[Fruity:49034] Signal: Bus error (10)
[Fruity:49034] Signal code: (2)
[Fruity:49034] Failing at address: 0x100336d7e
[Fruity:49034] [ 0] 2
浏览 4提问于2011-10-13得票数 0
回答已采纳
我在main中声明了int值，所有的进程都初始化了这个值。它们都是存储值，我想在计算完成后将其写在屏幕上。广播是一种解决方案吗？例如，如何实现它？
int i;
int value;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD,&numtasks);
MPI_Comm_rank(MPI_COMM_WORLD;&myrank);
left = (myrank - 1); if (left < 0) left = numtasks-1;
浏览 2提问于2011-02-27得票数 1
回答已采纳
1回答
我有一个分布式应用程序，在某些通信中使用MPI_Reduce()。在精度方面，用16位浮点数(半精度)得到了完全精确的结果.
为了加速通信(减少数据量)，是否有一种在16位浮点数上调用MPI_Reduce() 的方法？
(我查看了MPI文档，没有看到任何关于16位浮点数的信息。)
浏览 6提问于2015-04-14得票数 4
回答已采纳
1回答
我是MPI的新手，我正在尝试使用MPI_Reduce来找出整数数组的最大值。我有一个大小为arraysize的整数数组arr，下面是我的代码：
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &number_of_processes);
MPI_Comm_rank(MPI_COMM_WORLD, &my_process_id);
MPI_Bcast(arr, arraysize, MPI_INT, 0, MPI_COMM_WORLD);
MPI_Reduce(arr, &result, arra
浏览 1提问于2012-12-02得票数 2
回答已采纳
3回答
这个用于Pi近似的C应用程序总是输出每个问题大小相同的结果，即随机生成的点数(npts)。
#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include "mpi.h"
int main(int argc, char *argv[]) {
int myid,nprocs;
double PI25DT = 3.141592653589793238462643;
long long npts = 1e10;
long i,mynpts;
long
浏览 4提问于2017-10-27得票数 0
回答已采纳
1回答
我试图理解MPI_Reduce_scatter函数，但似乎我的演绎总是错误的：
文档显示()：
MPI_Reduce_scatter首先对sendbuf、count和datatype定义的发送缓冲区中的count = S(i)recvcountsi元素的向量进行元素级约简。接下来，结果向量被分割成n个不相交的段，其中n是组中的进程数。段一包含recvcountsi元素。ith段被发送到进程i，并存储在由recvbuf、recvcountsi和数据类型定义的接收缓冲区中。
我有以下(非常简单的)C程序，我希望得到第一个recvcountsi元素的最大值，但我似乎做错了什么……
#incl
浏览 0提问于2014-09-10得票数 13
回答已采纳
是否可以编写自己的Mpi_Bcast和Mpi_reduce，并将其命名为MyMpi_Bcast和MyMpi_Reduce？并有相同的论点，就像它有真正的Mpi_Bcast and Reduce。
1.int myMPI_Bcast( void *buffer, int count, MPI_Datatype datatype,int root, MPI_Comm comm);
2.int myMPI_Reduce( const void *sendbuf, void *recvbuf, int count,int root, MPI_Comm comm);
我的目的是比较真正的Mpi_Bcas
浏览 0提问于2018-03-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
