MPI_Reduce

@Satansoft · Регистрация: 27.02.2012

Author24 — интернет-сервис помощи студентам

Знаю, что на форуме темы с распределенными вычислениями средствами библиотеки MPI не популярны, но всё же.

Задача: Задать 11 процессов, 10 из которых генерят массивы из 1000 случайных чисел и передают их в 0 процесс, в котором MPI_Reduce их суммирует и выводит результат.

Прототип функции:

C++

1	int MPI_Reduce(void sendbuf, void recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm)

Код, который не работает:

C++

#include <stdio.h> 
#include <stdlib.h>
#include <mpi.h>
#include <conio.h> 
 
int main(int argc , char  *argv[]) {  
int me, size, max=1000;
int mass[1000];
int *recarray=new int[]; //динам. массив приема
MPI_Init(&argc , &argv); 
MPI_Comm_rank(MPI_COMM_WORLD, &me);
MPI_Comm_size(MPI_COMM_WORLD, &size);
 
if(me!=0){
for(int i=0; i<max;i++){
    mass[i]=rand()%max;} }
 
if(me==0){
MPI_Reduce(mass, recarray, size*max, MPI_INT, MPI_SUM, 0, MPI_COMM_WORLD);
printf("Proc %d Result: %d", me, recarray);}
 
MPI_Finalize();
delete recarray;
_getch();
return 0;
}

@Toshkarik · 28.09.2014, 01:46

Сообщение от Satansoft

int *recarray=new int[];

Нельзя так. Размер должен быть указан.

@Satansoft · 28.09.2014, 10:59 **[ТС]**

Сообщение от Toshkarik

Нельзя так. Размер должен быть указан.

дал размер в 10000, но работать она от этого не стала, правда получил десяток системных эрроров и ошибки VS на запись в память

@Satansoft · 28.09.2014, 11:09 **[ТС]**

Вариант с выводом только конечного результата

C++

#include <stdio.h> 
#include <stdlib.h>
#include <mpi.h>
#include <conio.h> 
 
int main(int argc , char  *argv[]) {  
int me, size, max=1000;
long int mass[1000];
int *recarray=new int[100000]; //динам. массив приема
MPI_Init(&argc , &argv);
 
MPI_Comm_rank(MPI_COMM_WORLD, &me);
MPI_Comm_size(MPI_COMM_WORLD, &size);
 
if(me!=0){
for(int i=0; i<max;i++){
    mass[i]=rand()%max;} }
 
MPI_Reduce(mass, recarray, size*max, MPI_INT, MPI_SUM, 0, MPI_COMM_WORLD);
 
if(me==0){
printf("Proc %d Result: %d", me, recarray);}
 
MPI_Finalize();
delete recarray;
_getch();
return 0;
}

@Toshkarik 1181 / 894 / 94 Регистрация: 03.08.2011 Сообщений: 2,461
	28.09.2014, 01:46	2
	Сообщение от Satansoft int *recarray=new int[]; Нельзя так. Размер должен быть указан. 1

@Satansoft 20 / 16 / 7 Регистрация: 27.02.2012 Сообщений: 742
	28.09.2014, 10:59 [ТС]	3
	Сообщение от Toshkarik Нельзя так. Размер должен быть указан. дал размер в 10000, но работать она от этого не стала, правда получил десяток системных эрроров и ошибки VS на запись в память 0

	28.09.2014, 11:09