MPI_Gather发送和接收数组错误
MPI_Gather是一种消息传递接口（Message Passing Interface）的函数，用于在并行计算中将各个进程中的数据收集到一个进程中。它的作用是将每个进程中的数据按照指定的顺序汇总到一个进程中，以便进行进一步的处理或分析。
MPI_Gather函数的原型如下：
int MPI_Gather(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm)参数解释：
- sendbuf：发送缓冲区的起始地址，即当前进程中要发送的数据。
- sendcount：发送缓冲区中的元素个数。
- sendtype：发送数据的数据类型。
- recvbuf：接收缓冲区的起始地址，即用于接收数据的进程中的缓冲区。
- recvcount：接收缓冲区中的元素个数。
- recvtype：接收数据的数据类型。
- root：接收数据的进程的标识符。
- comm：通信子，定义了参与通信的进程组。
MPI_Gather函数的工作原理是，每个进程将自己的数据发送给指定的接收进程，接收进程将接收到的数据按照指定的顺序存储到接收缓冲区中。发送和接收的数据类型和数量必须匹配，否则可能导致错误。
MPI_Gather函数的应用场景包括并行计算中的数据汇总、数据分析、结果收集等。它可以用于各种科学计算、数据处理、模拟等需要将多个进程中的数据合并的场景。
对于腾讯云的相关产品和产品介绍链接地址，可以参考以下内容：
- 腾讯云产品：腾讯云提供了丰富的云计算产品，包括云服务器、云数据库、云存储、人工智能等。具体可以参考腾讯云官方网站：https://cloud.tencent.com/
- 腾讯云MPI：腾讯云提供了基于MPI的高性能计算服务，可以满足并行计算的需求。具体可以参考腾讯云MPI产品介绍：https://cloud.tencent.com/product/mpi
需要注意的是，以上只是腾讯云的一些相关产品和介绍链接，其他云计算品牌商也提供类似的产品和服务，可以根据实际需求选择适合的云计算平台。
相关·内容
3回答
我正在使用MPI_Scatter和MPI_Gather实现矩阵乘法。如果进程的数量均匀地划分为矩阵的行数和列数，那么我的代码就可以正常工作。但是，当它们不均匀分配时，它会在MPI_Gather上崩溃。这是有意义的，因为MPI_Gather期望从每个进程获得一定的数量，而不会从最后一个进程获得那么多。有没有办法做到这一点呢？我查看了MPI_Gatherv，但我不希望数据之间有空格-我只希望它收到的数量少于上一次处理的数量。
目前，我使用MPI_Scatter向每个进程发送以下内容：
ceil(N/size)
其中size是我使用的进程数，N是矩阵中的行数和列数。最后一个进程接收的数据不会像其他进
浏览 0提问于2014-02-15得票数 4
我正在使用MPI编写我的第一个程序，我很难用MPI_Scatter正确地将数据发送到其他进程，修改它们并使用MPI_Gather接收值。守则如下：
int** matrix;
int m = 2, n = 2;
int status;
// could have been int matrix[2][2];
matrix = malloc(m*sizeof(int*));
for(i = 0; i < m; i++) {
matrix[i] = malloc(n*sizeof(int));
}
matrix[0][0] = 1;
matrix[0][1] = 2;
matri
浏览 5提问于2014-01-02得票数 1
回答已采纳
1回答
在MPI中传递多个变量
、、、
我正在尝试MPI中的一个实现，我在同一台机器(localhost)上调用多个从站(最多4个)，并在从站之间分配for循环的计算。MPI适用于我当前的应用程序，我不能采用openMP路由。所涉及的变量大约是50个，并且都是一维数组。将50个变量发送到主进程的最佳方式是什么？我应该发送和接收所有变量，还是应该将它们打包在一个二维数组中，然后将这个数组发送给master？我正在寻找一种高效且计算成本低廉的方法。
谢谢
浏览 2提问于2014-03-31得票数 0
我的排序程序可以很好地处理数组中的偶数元素，但会产生错误。
MPI_Gather中的致命错误:消息截断，错误堆栈: MPI_Gather(sbuf=0x00A2A700，scount=4，MPI_INT，rbuf=0x00A302C8，rcount=4，MPI_INT，root=0，MPI_COMM_WORLD)，失败消息来自1级和标记-1342177184截断；接收到28个字节，但缓冲区大小为16
数组中的奇数元素。问题从代码if ((world_rank == 1) && (n % world_size != 0))开始。我什么都试过了但都没用。我怎么才能解决这个问
浏览 5提问于2021-02-17得票数 2
回答已采纳
1回答
有4个进程，其中一个(0)是必须构建矩阵C的主进程，如下所示
-1 0 0 -1 0
0 -1 0 0 -1
-1 1 1 -1 1
1 -1 1 1 -1
-1 2 2 -1 2
2 -1 2 2 -1
-1 3 3 -1 3
3 -1 3 3 -1
为此，将矩阵声明为REAL, DIMENSION(:,:), ALLOCATABLE :: C，并使用
IF (myid == 0) THEN
ALLOCATE(C(2*nprocs,-2:+2))
END IF
其中nprocs是进程的数量。Process 0还设置了C = -1
浏览 1提问于2016-03-11得票数 0
回答已采纳
1回答
下面是我的代码应该如何工作。从节点将执行一些计算，每个节点将发送一个值，minE和相应的线性数组phi。根节点随后将接收2个值。我试图弄清楚如何在根节点中存储N-1 (从节点的数量) phi。我尝试在2D数组中接受phi，但它不起作用。或者我做错了。因此，此代码只从要发送的最后一个节点接收phi的值。
if (world_rank == root) {
for(i=1; i<world_size; i++) {
MPI_Irecv(&local_minE[i], 1, MPI_FLOAT, MPI_ANY_SOURCE, 1, MPI_COMM_WORLD
浏览 2提问于2016-04-11得票数 2
1回答
我正在用MPI和CGM现实的并行模型实现Chan和Dehne排序算法。到目前为止，每个进程从原始向量接收N/p号，然后每个进程使用快速排序顺序顺序排列它们的编号，然后每个进程从它的本地向量(样本有大小p)创建一个样本，然后每个进程将它们的样本发送到P0；P0应该接收大小为p*p的更大向量中的所有样本，以便能够容纳来自所有处理器的数据。这就是我被困的地方，它似乎在工作，但由于某种原因，在P0接收到它通过信号退出的所有数据之后:分段故障(11)。谢谢。
以下是守则的有关部分：
// Step 2. Each process calculates it's local sample with
浏览 1提问于2017-12-17得票数 1
回答已采纳
1回答
数组元素的和并行？
、、、、
我试图编写一个MPI程序来计算一个整数数组的和。
为此，我使用MPI_Scatter将数组的块发送到其他进程，然后使用MPI_Gather通过根进程(进程0)获取每个块的和。
问题是其中一个进程接收两个元素，另一个接收随机数。我正在用3个进程运行我的代码。
以下是我所拥有的：
#include <stdio.h>
#include <mpi.h>
int main(int argc,char *argv[]){
MPI_Init(NULL,NULL); // Initialize the MPI environment
int world_rank
浏览 2提问于2021-01-18得票数 2
回答已采纳
1回答
我是第一次使用MPI_Gather，并遵循了一些示例，但由于某些原因，每当我调用它时，都会收到seg错误。相关代码如下：
//Get the top N matches for each node
for (int j = 0; j < send_counts[id]; j++)
{
data = read_file(my_dir + files[rec_buf[j]]);
temp_results = circularSubvectorMatch(test_vectors[i], data, N);
res
浏览 1提问于2014-04-20得票数 1
1回答
我正在尝试将数据传递给MPI_Gather。我按如下方式分配内存：
float *phie, *phitemp;
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
phitemp=(float *) malloc(20*sizeof(float));
if (rank==1) phie=(float *) malloc(itermax*20*size*sizeof(float));
然后让所有进程使用MPI_Gather()将数据发送到排名1，如下所示：
for (iter=
浏览 0提问于2017-02-02得票数 0
因此，我要做的是将输入字符串"HELO“打印为"HEELLLOOOO”，到目前为止，我已经编写了以下代码
#include <mpi.h>
#include <stdio.h>
#include <string.h>
int main(int argc, char *argv[])
{
int i=0,rank,size;
MPI_Init(&argc,&argv);
MPI_Comm_size(MPI_COMM_WORLD,&size);
MPI_Comm_rank(MPI_COMM
浏览 2提问于2018-02-06得票数 0
回答已采纳
1回答
我对并行处理很陌生。我有一个按顺序计算和存储二维数组元素的例子。我想用MPI把它转换成一个并行程序。
以下是顺序程序的代码。
#include <stdio.h>
int x,y,xMax=10,yMax=10;
int main ()
{
int arr[yMax][xMax];
for(y =0; y<yMax;x++)
{
for (x=0;x<xMax;x++)
{
arr[y][x]=x+y;
printf("%d",arr[y][x]);
}
pr
浏览 2提问于2017-01-27得票数 0
回答已采纳
现在，我有了一个由单个master和多个worker组成的应用程序。应用程序需求非常简单:工作人员完成一些工作，然后将数据发送到master，master将这些数据分别存储到文件中。我可以简单地在worker端使用MPI_Send将数据发送给master。但是主机并不知道数据的发送顺序。有些工人走得快，有些人走得慢。更具体地说，假设有5个工作进程，那么发送数据的顺序可能是1,3,4,5,2或2,5,4,1,3。如果我只是用MPI_Recv在主端编写一个类似于for(i=1 to 5)的for循环来获取数据，那么主进程和一些速度更快的工作进程必须等待很长时间。我知道MPI_Gather可以实现这
浏览 4提问于2011-01-04得票数 1
回答已采纳
1回答
我需要编写代码，将矩阵的列从每个进程发送到根进程。
我有以下代码：
int task8(int argc, char* argv[])
{
int rank, size;
double matrix[100][150];
double result_matrix[100][150];
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &size);
// generate
浏览 4提问于2020-06-18得票数 0
回答已采纳
1回答
MPI分割故障
、、
我使用MPI并行运行一个程序，并测量执行时间。目前，我通过在“体素化”函数中提供一个开始和结束索引作为参数，将计算在每个进程之间进行分割。然后，这将在数据集的不同部分上工作，并将结果存储在"p_voxel_data“中。
然后，我希望使用"MPI_Gather“将所有这些子数组发送到根进程，这样就可以将数据写入文件并停止计时器。
当我将"MPI_Gather“行注释掉时，程序执行得很好，输出类似于以下内容：
Computing time: NODE 3 = 1.07 seconds.
Computing time: NODE 2 = 1.12 seconds.
但当这句
浏览 6提问于2014-03-27得票数 0
回答已采纳
假设k过程计算矩阵A的元素，其维数为(n，m)，其中n为行数，m为列数。我试图使用MPI_GATHER将这两个矩阵收集到根过程中的矩阵B中，其中B的维数为(n，km)。具体来说，我在下面编写了一个fortran代码示例。这里，我将矩阵A(不是整个矩阵)的列传递给矩阵B，但这是行不通的。当我使用mpirun -n 2 a.out运行可执行文件时，会得到以下错误：
malloc：*对象0x7ffa89413fb8错误:释放对象的校验和不正确-对象可能在被释放后被修改。
1)为什么我会收到这条错误消息？
2)谁能从概念上解释我为什么要使用MPI_TYPE_VECTOR？
3)如何纠正代码的MPI_G
浏览 3提问于2016-02-06得票数 1
回答已采纳
1回答
我试图使用MPI找到长度为100元素的数组的和，在仅使用MPI_Send和MPI_receive的限制下，我编写的代码找到每个处理器的和，但在向主处理器(rank=0)重新发送时，我的代码只从一个处理器接收。
我的密码
#include "stdafx.h"
#include <stdio.h>
#include <string.h>
#include "mpi.h"
#include "math.h"
int val = 1;
int main(int argc, char* argv[]) {
int my
浏览 1提问于2018-09-22得票数 0
回答已采纳
我在C语言中的MPI代码有问题。
我想我创造了一个很好的算法来处理一个二维数组的双循环。但是，当我尝试使用MPI_Gather从进程中收集数据时，会出现分割错误。以下是代码：
#define NN 4096
#define NM 4096
double global[NN][NM];
void range(int n1, int n2, int nprocs, int irank, int *ista, int *iend){
int iwork1;
int iwork2;
iwork1 = ( n2 - n1 + 1 ) / nprocs;
iwork2
浏览 0提问于2016-06-23得票数 1
回答已采纳
1回答
我需要在我的矩阵乘法程序中使用MPI_Gather函数，但在过去的几天里遇到了麻烦。
因此，我单独使用gather函数编写了一个简单的MPI程序，并一直在尝试让它运行……关于这一点，我参考了彼得·帕切科的书“并行编程入门”。
程序直接退出，没有给出任何结果或错误...到目前为止，我还没能弄清楚这个错误。
/******************NOTE**********************
The program simply uses the MPI_Gather() function.
The program is exiting directly.
浏览 0提问于2012-10-03得票数 1
1回答
我正在使用MPI执行代码并行化，以评估成本函数。
我将种群划分为8个处理器中的50,000个点。
我正在尝试并行化以下代码，但遇到了困难：
//mpiWorldSize is number of processors
//=====================================
for (int k=1; k< mpiWorldSize; k++)
{
MPI_Send(params[1][mpiWorldRank*over+k],7,MPI_INT, 0,0,MPI_COMM_WORLD);
}
// evaluate all the new costs
浏览 1提问于2014-12-05得票数 0
我对MPI很陌生，并试图在多个线程上并行化代码。我需要将一大块数据传输回主线程，并且无法清理MPI_Gather之后的内存垃圾。下面是示例代码：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mpi.h>
int main (int argc, char *argv[]) {
MPI_Init(&argc, &argv);
int rank, world_size;
MPI_Comm_rank(MPI_COMM_WORLD, &
浏览 0提问于2018-05-23得票数 2
回答已采纳
1回答
发送矩阵列(C++)
、、、
我试图将矩阵的第二列和第三列从具有MPI的一级和二级进程发送到具有零级的进程。
在互联网上，我找到了这个示例并编写了一个代码：
#include <iostream>
#include <mpi.h>
using namespace std;
int main(int argc, char *argv[]) {
int id;
int matrix[3][3];
int matrixB[9];
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &
浏览 3提问于2015-01-20得票数 2
回答已采纳
1回答
我尝试将代码与MPI并行化。在此代码中，要并行化的部分位于函数中。我必须将顺序循环转换为MPI并行循环。
在这个MPI循环之后，我必须得到一个全局数组，并且我打算使用MPI_Gather来拥有这个数组。
下面是代码的结构：
int main() {
double *array_global;
data1 = read(file1);
data2 = read(file2);
data3 = compute_on_data(data1, data2);
write(file3,data3);
function_to_parallelize
浏览 5提问于2014-08-01得票数 0
回答已采纳
1回答
我是用Fortran进行MPI编程的新手。我想画一张二维图。我正在尝试让每个处理器计算图的一个点，并将其发送到root，以便将其写入文件。谁能告诉我如何发送两个变量，即：x和f(x)与mpi_gather。谢谢你的帮助。
浏览 2提问于2012-12-04得票数 1
1回答
MPI_Gather二维阵列
、、、、
N是4，N_glob也是。正好是同样的尺寸。p是4。
下面是代码的一小部分：
float **global_grid;
float **gridPtr;
lengthSubN = N/pSqrt;
subN = lengthSubN + 2;
grid = allocate2D(grid, subN, subN);
..
MPI_Type_contiguous(lengthSubN, MPI_FLOAT, &rowType);
MPI_Type_commit(&rowType);
..
gridPtr = grid;
..
MPI_Barrier(MPI_COMM_WORLD
浏览 0提问于2015-12-30得票数 1
回答已采纳
Hallo我正在尝试用C语言编写一个使用MPI的简单并行程序。程序应该在数组中找到最大值。根进程应使用MPI_Scatter将数组块发送到所有进程，然后通过MPI_Gather收集结果。当我运行这个程序时，我得到的一般错误如下：
这条Unix错误消息可能会有所帮助: Unix errno: 14 Bad address
我知道MPI_Scatter和MPI_Gather或者我发送给这个函数的值有一些问题。
我试图找到解决方案，但我没有找到任何有用的东西。
下面是我的代码：
#include <mpi.h>
#include <stdio.h>
#includ
浏览 2提问于2013-10-16得票数 0
1回答
我是MPI的新手。我有4个进程:进程1到进程3填充向量并将其发送到进程0，进程0将向量收集到一个非常长的向量中。我有工作的代码(太长而不能发布)，但是进程0的recv操作很笨拙而且非常慢。
在抽象的情况下，代码做了以下工作：
MPI::Init();
int id = MPI::COMM_WORLD.Get_rank();
if(id>0) {
double* my_array = new double[n*m]; //n,m are int
Populate(my_array, id);
MPI::COMM_WORLD.Send(my_array,n*m,MP
浏览 1提问于2012-05-07得票数 7
1回答
在MPI，C++上分配单堆栈数组
、、、、
这是问题所在。我有一些“小”数组，我不想把它们MPI_Gather成一个大数组，但我只想在根(0)线程上分配一个大数组。
#include <mpi.h>
#include <iostream>
int main(int argc, char **argv) {
int rank, numprocs;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &numprocs
浏览 12提问于2016-09-17得票数 0
现在，我正在尝试使用MPI_Sendand MPI_Recv在多个进程中传递找到的最佳解决方案。在每个过程中找到的最佳解决方案应该传递给控制过程，控制过程存储所有最佳解决方案，并在需要时发送给其他过程。我的问题是如何实现它？例如，一旦进程1找到新的最佳，它就可以调用MPI_Send并将其发送到控制进程。有没有一种方法可以让控制进程检测到有消息要接收？每个MPI_Send都需要MPI_Recv吗？期待着听取各位专家的意见。谢谢!
谢谢你的建议。我想要做的是让几个工作进程向一个控制进程发送消息。工作过程决定何时发送。控制过程必须检测何时接收。MPI_Proble能做到这一点吗？
浏览 0提问于2010-02-26得票数 5
回答已采纳
1回答
我希望运行一个效率测试，用MPI查找全局最大值，一次使用环拓扑，然后再使用MPI_REDUCE函数。我已经在我的代码中做了MPI_REDUCE，它运行得很好，但是我想通过环传递产生同样的结果。
我的想法是为每个处理器的局部极大值创建一个数组，然后通过环传递这些最大值，最后输出全局最大值。
不幸的是，我意识到我无法定义一个包含进程极大值的数组，相反，我最终从4个进程生成了4个不同的数组。然后我开始传递从秩=0处理器开始的数组值，而不是只传递一个最大值，我必须传递4个不同的数组值，因为我生成了4个不同的数组。更糟糕的是，即使做了这么多努力，我也没有得到全局最大值，因为我只是从一行MPI_REDUC
浏览 2提问于2016-11-16得票数 0
我有一个分布在MPI进程网格上的2D数组(在本例中为3 x 2进程)。数组的值是在将数组的块分发到的进程中生成的，我希望在根进程中将所有这些块收集在一起以显示它们。
到目前为止，我有下面的代码。这将生成一个笛卡尔通信器，找出MPI过程的坐标，并根据该坐标计算出它应该获得多少数组(因为数组不需要是笛卡尔网格大小的倍数)。然后，我创建了一个新的MPI派生数据类型，它将整个进程子数组作为一个项发送(即，每个进程的步长、块长度和计数都不同，因为每个进程具有不同大小的数组)。然而，当我使用MPI_Gather收集数据时，我得到了一个分段错误。
我认为这是因为我不应该在MPI_Gather调用中使用相同的
浏览 2提问于2011-04-03得票数 3
回答已采纳
我想使用MPI_Gather将数据发送到0级。但我做错了事：
int size;
int rank;
int i;
int b;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &size);
int* bb= new int[size];
//slave
if(rank!=0) {·
b=13;·
printf("slave %d \n", b);
// sleep(5);
M
浏览 2提问于2014-08-30得票数 0
回答已采纳
1回答
我正在编写一个MPI版本的数组更新，其中我正在从多个进程更新单个数组。以下是我的代码-
uint n_sigm;
int *suma_sigm;
int my_first_i = 0;
int my_last_i = 0;
using namespace std;
int main(int argc, char *argv[])
{
int rank, size, i;
MPI_Status status;
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(M
浏览 3提问于2014-05-01得票数 0
回答已采纳
我在每个进程上都有不同长度的np进程和np不同的数组。我必须将其中一个发送给每个进程(对所有过程重复相同)。其中一个np部件应该保留在该流程上。
在三个过程中，应该是：
p0有[A0 B0 C0]，最终应该有[A0 A1 A2]
p1有[A1 B1 C1]，最终应该有[B0 B1 B2]
p2有[A2 B2 C2]，最终应该有[C0 C1 C2]
我的想法是先收集所有长度，然后分配内存，最后执行一个MPI_gatherv操作，同时更改根级别，同时进行共享信息，如下所示：
#include <stdio.h>
#include <stdlib.h>
#includ
浏览 2提问于2017-06-22得票数 0
回答已采纳
1回答
我已经设置了一个包含两个整数向量的向量，现在我想通过OpenMPI发送和接收它，这样我就可以在从节点上对这个结构进行计算。如果可能的话，我想一口气把这个笨重的结构...
在main上，我声明了我的向量，并使其对发送端和接收端都是通用的：
std::vector < std::vector<int> > temp;
在发送端，我填充了这个结构，后来，我尝试发送它：
MPI_Send(&temp[0], 2, MPI_INT, 1, 0, MPI_COMM_WORLD);
而且，在接收端，我一直在执行：
temp.resize(2);
MPI_Recv(&t
浏览 0提问于2017-12-23得票数 0
MPI_Gatherv是MPI的一个接口，如下所示：
int MPI_Gatherv(
void* sendbuf,
int sendcount,
MPI_Datatype sendtype,
void* recvbuf,
int *recvcounts,
int *displs,
MPI_Datatype recvtype,
int root,
MPI_Comm comm)
"recvcounts“的类型是"int *”，这样我们就可以分别为每个进程设置要接收的项的计数；然而，我发现这是不可能实现的：
当
浏览 1提问于2011-09-21得票数 1
2回答
我的收集缓冲器是空的？
、、、
我在从所有进程收集数据以处理主进程"root“时遇到了问题，我可以发送数据MPI_Bcast，但是在MPI_Gather上，我在countBuff中遇到了所有问题，我调试了输出，这就是我所拥有的
output
brodcast data of 0
brodcast data of 1
MPI_Gather data rank 0 1
from 0 to 1.00 KM:-842150451,from 1.00 to 2.00 KM:-842150451,from 2.00 to 5.00 KM:-842150451,grater than 5.00
浏览 1提问于2013-11-24得票数 0
回答已采纳
我有一个包，其中包含了几个包含和任务，我使用了错误事件处理程序中的发送邮件任务来发送邮件，如果在加载过程中发生任何错误。但是当包中出现错误时，发送邮件任务已经执行了两次或三次(发送邮件)，具有不同的错误描述。我只需要接收一封带有所有错误描述的邮件，而不是多封邮件。
请让我知道如何做到这一点。
浏览 1提问于2015-04-18得票数 1
回答已采纳
我有一个使用MPI_Scatter()和MPI_Gather()的程序。程序以整数N作为输入，并将素数从2返回到N。我创建一个数组，该数组的数目为2到N，MPI_Scatter将数组拆分为N/(procs数)元素，然后将它们分配给进程。如果我插入一个对进程数( 'size‘)是可除的数字N，那么一切都可以正常工作，但是当我输入一个不能被“大小”整除的N时，我会有一些错误。例如: N=16和size=4 => 16/4= 4，所以是N%size==0，但是当N%size!=0时，就会有错误。我试着补充：
div = N/size;
if (N%size != 0)
if (
浏览 5提问于2014-01-24得票数 11
回答已采纳
下面是我试图用我的代码做的事情。
我必须计算二维网格上的Fw和Fi，这是nx大小的nz。我在所有处理器之间分割k循环，以便每个处理器计算nx (nz/p)，其中p是所使用的处理器数。在每个处理器完成后，我想收集所有的块，即nz/p Fw和Fi中的每个nx，并将其放入根中的Fw和Fi中。我最终想要使用all，即将所有计算出来的Fw和Fi收集到所有处理器中。
我已经附上了下面的代码。
我不确定我是否指定sendcount和recvcount正确，也不确定为什么我的代码是死锁的。任何帮助都是非常感谢的。谢谢!
PROGRAM gridtestpar
IMPLICIT NONE
INTEGE
浏览 1提问于2013-03-13得票数 1
1回答
我有一个平行的高斯消去码。调用MPI_Gather函数调用时会发生分段错误。我知道，如果没有为任何一个缓冲区正确分配内存，这种错误可能会出现。但是我看不出内存管理代码有什么问题。
有人能帮忙吗？
谢谢。
注释：程序从一个名为input.txt的目录中的.txt文件中读取。
代码：
#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include "mpi.h"
/*void print2dAddresses(double** array2d, int rows, int co
浏览 4提问于2013-05-15得票数 2
1回答
这是的后续问题.情况如下：
id = 0 has this submatrix
|16.000000| |11.000000| |12.000000| |15.000000|
|6.000000| |1.000000| |2.000000| |5.000000|
|8.000000| |3.000000| |4.000000| |7.000000|
|14.000000| |9.000000| |10.000000| |13.000000|
-----------------------
id = 1 has this submatrix
|12.000000| |15.000000|
浏览 2提问于2015-12-31得票数 2
回答已采纳
1回答
我要在这个夏天掌握MPI。我开始阅读彼得·帕切科( Pacheco )的“并行编程入门”，并解决它的练习。在其中一个MPI练习中，他要求用MPI_Scan实现简单的前缀和，但我不能用MPI_Scan实现它。我通过使用MPI_Scatter和MPI_Gather找到了一个解决方案。请帮我找到MPI_Scan的答案。
// declaring array and result
// generating random array
MPI_Bcast( &array, n, MPI_FLOAT, 0, MPI_COMM_WORLD);
MPI_Barrier(MPI_COMM_WORLD);
浏览 0提问于2012-08-06得票数 0
回答已采纳
1回答
我有一个函数，它根据秩在数组中存储一些数字，完成后，我希望有一个更大的数组，其中包含所有处理器的结果。假设我有4个处理器，并按如下方式运行程序
mpirun -np 4 storesArrays.out
这是我的代码
int main(int argc, char *argv[])
{
MPI_Init(&argc, &argv);
int currRank;
MPI_Comm_rank(MPI_COMM_WORLD, &currRank);
int numRanks;
MPI_Comm_size(MPI_COMM_WORLD, &numRank
浏览 0提问于2014-08-28得票数 0
在MPI中MPI_Allgather函数和MPI_Alltoall函数的主要区别是什么？
我的意思是，谁能给我举个例子，在哪里MPI_Allgather会有帮助，而MPI_Alltoall不会？反之亦然。
我不能理解主要的区别？看起来，在这两种情况下，所有进程都将send_cnt元素发送到参与通信器的每个其他进程，并接收它们？
谢谢
浏览 10提问于2013-02-24得票数 24
回答已采纳
我试图制作一个迷你C程序来理解MPI，我想让用户输入程序将接收多少个数字、数字，然后在进程上平等地scatter它们。然后每个进程将计算它的局部平均值，然后使用gather根进程将计算整个平均值。数字存储在一个大小固定的数组中。我的问题是，根过程不计算平均值，我不知道为什么。像我在其他例子中看到的那样，我分散并收集了这些数字，但我无法做到。这就是我所拥有的。
#include <stdio.h>
#include "mpi.h"
int main(int argc, char** argv){
int my_rank;
int p;
int n;
int i;
i
浏览 0提问于2021-01-01得票数 2
回答已采纳
1回答
假设一个程序在xp乘以yp乘以zp进程上运行。笛卡儿通信器的使用，使这些过程可以被认为是安排在一个网格的维度(xp，yp，zp)。在这个程序中，根进程(0)声明并分配一个3D数组Atot，该数组将由每个进程声明的3D数组A填充(包括根)。
INTEGER, DIMENSION(3) :: Ntot
INTEGER, DIMENSION(3) :: N
INTEGER, DIMENSION(:,:,:), ALLOCATABLE :: Atot
INTEGER, DIMENSION(:,:,:), ALLOCATABLE :: A
:
! the 3 elements of the array
浏览 4提问于2016-05-30得票数 1
如何使用VirtualLibrary发送和接收Arduino中的整数数组。我声明了这样的数组：
int toSend[] = {1,4,5,7,9};
如何正确发送和接收？也许有人能帮我？
浏览 2提问于2014-08-27得票数 1
回答已采纳
1回答
MPI只从根过程收集
、、、
首先，我一直使用作为参考，这说明了没有MPI_Scatter的MPI_Gather的使用，因为这正是我在这里试图实现的。我已经做了很长一段时间了，只是找不出问题。这种sobel边缘检测算法增强了图像中物体的轮廓。
我将在下面张贴我的代码，因为没有太多，但我将首先给出一个快速的代码描述。
我正在尝试将一个顺序程序转换成一个并行程序。所以所有的非MPI代码都是正确的。
因此，我的MPI代码只会出现错误。
int main(int argc, char **argv) {
FILE *inFile, *oFile;
int grayImage[N][N], edgeImage[
浏览 5提问于2016-10-18得票数 0
回答已采纳
我有一个起始位置数组，用于读取程序中每个baby节点的文件。我尝试让头节点将开始读取文件的位置发送给每个节点，然后让它们返回结果。
困难的是文件中没有完美数量的节点行，因此必须反复使用它们。为此，我尝试使用for循环进行发送和接收，其中头节点根据文件中的行数发送消息，而子节点接收文件中的行数除以婴儿节点数的消息。
简单地说，这对我来说是行不通的，我真的不知道该怎么办。
if(qNum == 1){ //If query Number is one
if(firstSource == 1){ //And the source is equal to 1
if(my_ra
浏览 0提问于2015-12-09得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
