Параллельное программирование

Пример MPI_Scatterv

• #include “mpi.h”
• #include
• int main (int argc, char *argv[])
• {
• int gsize,*sendbuf, root, rbuf[100], i, *displs, *scounts;
• MPI_Init(&argc, &argv);
• MPI_Comm_size(comm, &gsize);
• sendbuf = malloc(gsize*stride*sizeof(int));
• displs = malloc(gsize*sizeof(int));
• scounts = malloc(gsize*sizeof(int));
• for (i=0; i
• {
• displs[i] = i*stride;
• scounts[i] = 100;
• }
• MPI_Scatterv( sendbuf, scounts, displs, MPI_INT, rbuf, 100, MPI_INT,
• root, MPI_COMM_WORLD);
• MPI_Finalize();
• return 0;
• }

• Параллельное программирование с использованием технологии MPI Аксёнов С.В.

Сбор данных MPI_Gather

• Параллельное программирование с использованием технологии MPI Аксёнов С.В.

• int MPI_Gather(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 Аксёнов С.В.