Пример работы MPI-программы
К пакету MPICH прилагается об­ра­зец MPI-про­грам­мы: C:\​Program Files\​MPICH2\​examples\​cpi.exe (ис­ход­ный код см. ниже). Это про­стая про­грам­ма, при­бли­жён­но вы­чис­ляю­щая зна­че­ние чис­ла Пи пу­тём чис­лен­но­го вы­чис­ле­ния сле­дую­ще­го ин­тег­ра­ла:

Вна­ча­ле за­пу­стим один, два, и че­ты­ре про­цес­са на «головном» ком­пью­те­ре. Что­бы MPICH не рас­пре­де­лял за­пус­кае­мые про­цес­сы меж­ду имею­щи­ми­ся уз­ла­ми, от­клю­чим ра­бо­ту с се­тью; для это­го су­ще­ству­ет ключ ко­манд­ной стро­ки -localonly. При его до­бав­ле­нии ме­не­джер про­цес­сов не ис­поль­зу­ет­ся. Это очень по­лез­но, ес­ли по ка­ким-ли­бо при­чи­нам MPICH не уда­ёт­ся на­стро­ить. Вве­ди­те этот ключ в по­ле «extra mpiexec options».

По­лу­чено сле­дую­щее вре­мя вы­чис­ле­ния на од­ном ком­пью­те­ре: 1 про­цесс — 1.424 се­кун­ды, 2 про­цес­са — 0.7801 се­кун­ды, 4 про­цес­са — 0.7766 се­кун­ды. Вид­но, что два про­цес­са вы­пол­ни­ли вы­чис­ле­ния по­чти в 2 ра­за быст­рее, чем один про­цесс, в то вре­мя как ис­поль­зо­ва­ние 4-х про­цес­сов не да­ло даль­ней­ше­го вы­иг­ры­ша в ско­ро­сти.

---

Со­зда­ние MPI-про­грам­мы в Visual Studio

Пре­жде все­го, нуж­но на­строим Visual Studio, что­бы он на­хо­дил за­го­ло­воч­ные фай­лы и .lib-биб­лио­те­ки MPICH. Для это­го за­пу­скаем Visual Studio и  Tools → Options, в де­ре­ве сле­ва вы­бе­раем Projects and Solutions → VC++ Directories. Спра­ва-ввер­ху вы­бе­рем Show directories for: Include files. Путь к .h-фай­лам (рис. 2.1.)





Ри­с 2.1. На­строй­ка пу­ти к за­го­ло­воч­ным фай­лам MPICH

По­сле это­го про­де­лаем ту же про­це­ду­ру для биб­лио­тек (Show directories for: Library files) (Рис. 2.2.):





Ри­с 2.2. На­строй­ка пу­ти к биб­лио­теч­ным фай­лам MPICH

Те­перь со­здаем кон­соль­ный про­ект. От­кроем ок­но на­стро­ек про­ек­та (Project → Properties), вы­бе­рем Configuration: All Configurations, в де­ре­ве сле­ва вы­бе­ри­те Configuration Properties → Linker → Input. До­бавим mpi.lib в по­ле Additional Dependencies спра­ва (Рис. 2.3.):



Ри­с 2.3. До­бав­ле­ние mpi.lib к про­грам­ме
Исходный код примера 2.1

/* This is an interactive version of cpi */

#include "mpi.h"

#include

#include

#include

double f(double);

int main(int argc, char **argv)

{

int done = 0,

n,

myid,

numprocs,

i;

double PI25DT = 3.141592653589793238462643;

double mypi,

pi,

h,

sum,

x;

double startwtime = 0.0,

endwtime;

int namelen;

char processor_name[MPI_MAX_PROCESSOR_NAME];

MPI_Init(&argc,&argv);

MPI_Comm_size(MPI_COMM_WORLD,&numprocs);

MPI_Comm_rank(MPI_COMM_WORLD,&myid);

MPI_Get_processor_name(processor_name,&namelen);

/*

fprintf(stdout,"Process %d of %d is on %s\n",

myid, numprocs, processor_name);

fflush(stdout);

*/

while (!done)

{

if (myid == 0)

{

fprintf(stdout, "Enter the number of intervals: (0 quits) ");

fflush(stdout);

if (scanf("%d",&n) != 1)

{

fprintf( stdout, "No number entered; quitting\n" );

n = 0;

}

startwtime = MPI_Wtime();

}

MPI_Bcast(&n, 1, MPI_INT, 0, MPI_COMM_WORLD);

if (n == 0)

done = 1;

else

{

h = 1.0 / (double) n;

sum = 0.0;

for (i = myid + 1; i <= n; i += numprocs)

{

x = h * ((double)i - 0.5);

sum += f(x);

}

mypi = h * sum;

MPI_Reduce(&mypi, &pi, 1, MPI_DOUBLE, MPI_SUM, 0,

MPI_COMM_WORLD);

if (myid == 0)

{

printf("pi is approximately %.16f, Error is %.16f\n",

pi, fabs(pi - PI25DT));

endwtime = MPI_Wtime();

printf("wall clock time = %f\n", endwtime-startwtime);

fflush( stdout );

}

}

}

MPI_Finalize();

_getch();

return(0);

}

double f(double a)

{

return (4.0 / (1.0 + a*a));

}

Методы распараллеливания и модели программ, поддерживаемые MPI

Одной из целей, преследуемых при решении задач на вычислительных системах, в том числе и на параллельных, – является эффективность. Эффективность параллельной программы существенно зависит от соотношения времени вычислений ко времени коммуникаций между компьютерами (при обмене данными). И чем меньше в процентном отношении доля времени, затраченного на коммуникации, в общем времени вычислений, тем больше эффективность. Для параллельных систем с передачей сообщений оптимальное соотношение между вычислениями и коммуникациями обеспечивают методы крупнозернистого распараллеливания, когда параллельные алгоритмы строятся из крупных и редко взаимодействующих блоков. Задачи линейной алгебры, задачи, решаемые сеточными методами и многие другие, достаточно эффективно распараллеливаются крупнозернистыми методами.

MPMD - модель вычислений. MPI - программа представляет собой совокупность автономных процессов, функционирующих под управлением своих собственных программ и взаимодействующих посредством стандартного набора библиотечных процедур для передачи и приема сообщений. Таким образом, в самом общем случае MPI - программа реализует MPMD - модель программирования (Multiple program - Multiple Data).

SPMD - модель вычислений. Все процессы исполняют в общем случае различные ветви одной и той же программы. Такой подход обусловлен тем обстоятельством, что задача может быть достаточно естественным образом разбита на подзадачи, решаемые по одному алгоритму. На практике чаще всего встречается именно эта модель программирования (Single program - Multiple Data).

Последнюю модель иначе можно назвать моделью распараллеливания по данным. Кратко, суть этого способа заключается в следующем. Исходные данные задачи распределяются по процессам (ветвям параллельного алгоритма), а алгоритм является одним и тем же во всех процессах, но действия этого алгоритма распределяются в соответствии с имеющимися в этих процессах данными. Распределение действий алгоритма заключается, например, в присвоении разных значений переменным одних и тех же циклов в разных ветвях, либо в исполнении в разных ветвях разного количества витков одних и тех же циклов и т.п. Другими словами, процесс в каждой ветви следует различными путями выполнения на той же самой программе.

Виртуальные топологии

В этом пункте описываем механизм виртуальных топологий MPI. Под виртуальной топологией здесь понимается программно реализуемая топология в виде конкретного графа, например: кольцо, решетка, тор, звезда, дерево и вообще произвольно задаваемый граф на существующей физической топологии. Виртуальная топология обеспечивает очень удобный механизм наименования процессов, связанных коммуникатором, и является мощным средством отображения процессов на оборудование системы. Виртуальная топология в MPI может задаваться только в группе процессов, объединенных коммуникатором.

Нужно различать виртуальную топологию процессов и топологию основного, физического оборудования. Механизм виртуальных топологий значительно упрощает и облегчает написание параллельных программ, делает программы легко читаемыми и понятными. Пользователю при этом не нужно программировать схему физических связей процессоров, а только программировать схему виртуальных связей между процессами. Отображение виртуальных связей на физические связи осуществляет система, что делает параллельные программы машинно-независимыми и легко переносимыми. Функции в этой главе осуществляют только машинно-независимое отображение.

Функции создания декартовых топологий

Функция, конструирующая декартову топологию

MPI_CART_CREATE используется для описания декартовой структуры произвольного измерения. Для каждого направления координаты определяется, является ли структура процесса периодической или нет.

MPI_CART_CREATE(comm_old, ndims, dims, periods, reorder, comm_cart)

IN comm_old входной (старый) коммуникатор

IN ndims количество измерений в декартовой топологии

IN dims целочисленный массив размером ndims, определяющий количество процессов в каждом измерении

IN periods массив размером ndims логических значений,определяющих переодичность (true) или нет (false) в каждом измерении

IN reorder ранги могут быть перуномерованы (true) или нет (false)

OUT comm_cart коммуникатор новой (созданой) декартовой топологии

int MPI_Cart_create(MPI_Comm comm_old, int ndims, int *dims, int *periods, int reorder, MPI Comm *comm_cart)

MPI_CART_CREATE возвращает управление новому коммуникатору, к которому присоединена информация декартовой топологии. Эта функция коллективная. Как в случае с другими коллективными функциями, вызов этой функции должен быть синхронизован во всех процессах. Если reorder = false, тогда номер каждого процесса в новой группе идентичен ее номеру в старой группе. Иначе, функция может переупорядочивать процессы (возможно чтобы выбрать хорошее отображение виртуальной топологии на физическую топологию). Если полный размер декартовой сетки меньше чем размер группы comm_old, то некоторые процессы возвращают MPI_COMM_NULL, по аналогии с MPI_COMM_SPLIT. Запрос ошибочен, если он определяет сетку, которая является большей, чем размер группы comm_old (Рис. 3.1).

0 (0,0)	1 (0,1)	2 (0,2)	3 (0,3)
4 (1,0)	5 (1,1)	6 (1,2)	7 (1,3)
8 (2,0)	9 (2,1)	10 (2,2)	11 (2,3)

Рис. 3.1. Связь между рангами и декартовыми координатами для 3x4 2D топологии. Верхний номер в каждой клетке - номер процесса, а нижнее значение (строка, столбец) - координаты.

Декартова функция задания решетки

Для декартовой топологии, функция MPI_DIMS_CREATE помогает пользователю выбрать сбалансированное распределение процессов по направлению координат, в зависимости от числа процессов в группе, и необязательных ограничений, которые могут быть определены пользователем. Одно возможное использование этой функции это разбиение всех процессов (размер группы MPI_COMM_WORLD) в N-мерную топологию.

MPI_DIMS_CREATE(nnodes, ndims, dims)

IN nnodes количество узлов в решетке

IN ndims размерность декартовой топологии

INOUT dims целочисленный массив, определяющий

количество узлов в каждой размерности

int MPI_Dims_create(int nnodes, int ndims, int *dims)

Элементы в массиве dims представляют описание декартовой решетки с размерностями ndims и общим количеством узлов nnodes. Размерности устанавливаются так, чтобы быть близко друг к другу насколько возможно, используя соответствующий алгоритм делимости. Пользователь может ограничивать действие этой функции, определяя элементы массива dims. Если в dims[i] уже записано число, то функция не будет изменять количество узлов в измерении i; функция модифицирует только нулевые элементы в массиве, т.е. где dims[i] = 0. Отрицательные значения элементов dims(i) ошибочены. Ошибка будет выдаваться, если nnodes не кратно П dims[i].

(i,dims[i]¹0)

Для dims[i] установленных функцией, dims[i] будут упорядочены в монотонно уменьшающемся порядке. Массив dims подходит для использования, как вход к функции MPI_CART_CREATE. Функция MPI_DIMS_CREATE локальная. Отдельные типовые запросы показываются на Рис 3.2.

dims перед вызовом	Функции	Dims после возврата
(0,0) (0,0) (0,3,0) (0,3,0)	MPI_DIMS_CREATE(6, 2, dims) MPI_DIMS_CREATE(7, 2, dims) MPI_DIMS_CREATE(6, 3, dims) MPI_DIMS_CREATE(6, 3, dims)	(3,2) (7,1) (2,3,1) ошибка

Рис. 3.2. Отдельные типовые запросы к функции MPI_DIMS_CREATE.

Декартовы информационные функции

Если декартова топология создана, может возникнуть необходимость запросить информацию относительно этой топологии. Эти функции даются ниже и все они локальные.

MPI_CARTDIM_GET(comm, ndims)

IN comm коммуникатор с декартовой топологией

OUT ndims размерность декартовой топологии

int MPI_Cartdim_get(MPI_Comm comm, int *ndims)

MPI_CARTDIM_GET возвращает число измерений декартовой топологии, связанной с коммуникатором comm. Коммуникатор с топологией на рис. 1.2 возвратил бы ndims = 2.

MPI_CART_GET(comm, maxdims, dims, periods, coords)

IN comm коммуникатор с декартовой топологией

IN maxdims максимальный размер массивов dims,

periods, и coords в вызывающей программе

OUT dims массив значений, указывающих количество

процессов в каждом измерении

OUT periods массив значений, указывающих

периодичность (true/false) в каждом измерении

OUT coords координаты вызвавшего процесса в

декартовой топологии

int MPI_Cart_get(MPI_Comm comm, int maxdims, int *dims,

int *periods, int *coords)

MPI_CART_GET возвращает информацию относительно декартовой топологии, связанной с коммуникатором comm. maxdims должен быть, по крайней мере, равен ndims, как возвращает MPI_CARTDIM_GET. Для примера на рис. 1.2, dims = (3,4), а в процессе 6 функция возвратит coords = (1,2).

Декартовы функции транслирования

Функции, приведенные в этом пункте переводят на\из ранга в декартовы координаты топологии. Эти запросы локальные.

MPI_CART_RANK(comm, coords, rank)

IN comm коммуникатор с декартовой топологией

IN coords целочисленный массив, определяющий

координаты нужного процесса в

декартовой топологии

OUT rank ранг нужного процесса

int MPI_Cart_rank(MPI_Comm comm, int *coords, int *rank)

Для группы процессов с декартовой структурой функция MPI_CART_RANK переводит логические координаты процессов в номера. Эти номера процессы используют в парных взаимодействиях между процессами. coords - массив размером ndims как возвращает MPI_CARTDIM_GET. Для примера на рис. 1.2 процесс с coords = (1,2) возвратил бы rank = 6. Для измерения i с periods(i) = true, если координата, coords(i), находится вне диапазона, то есть coords(i) < 0 или coords(i) >= dims(i), она перемещается назад к интервалу 0 <= coords(i) < dims(i) автоматически. Если топология на рис. 1.2 периодическая в обеих размерностях, то процесс с coords = (4,6) также возвратил бы rank = 6. Для непериодических размерностей диапазон вне координат ошибочен.

MPI_CART_COORDS(comm, rank, maxdims, coords)

IN comm коммуникатор с декартовой

топологией

IN rank ранг процесса в торологии comm

IN maxdims максимальный размер массивов dims,

periods, и coords в вызывающей программе

OUT coords целочисленный массив, определяющий

координаты нужного процесса в декартовой топологии

int MPI_Cart_coords(MPI_Comm comm, int rank, int maxdims, int *coords)

MPI_CART_COORDS – переводит номер процесса в координаты процесса в топологии. Это обратное отображение MPI_CART_RANK. maxdims можно взять, например, равным ndims, возвращенным MPI_CARTDIM_GET. Для примера на рис. 1.2, процесс с rank = 6 возвратил бы coords = (1,2).

Декартова функция смещения

Если в декартовой топологии, используется функция MPI_SENDRECV (см. далее п. 3.2) для смещения данных вдоль направления какой либо координаты, то входным аргументом MPI_SENDRECV берется номер процесса source (процесса источника) для приема данных, и номер процесса dest (процесса назначения) для передачи данных. Операция смещения в декартовой топологии определяется координатой смещения и размером шага смещения (положительным или отрицательным). Функция MPI_CART_SHIFT возвращает информацию для входных спецификаций, требуемых в вызове MPI_SENDRECV. Функция MPI_CART_SHIFT локальная.

MPI_CART_SHIFT(comm, direction, disp, rank_source, rank_dest)

IN comm коммуникатор с декартовой

топологией

IN direction номер измерения (в топологии), где

делается смещение

IN disp направление смещения (> 0:

смещение в сторону увеличения номеров координаты direction, < 0:

смещение в сторону уменьшения номеров координаты direction)

OUT rank_source ранг процесса источника

OUT rank_dest ранг процесса назначения

int MPI_Cart_shift(MPI_Comm comm, int direction, int

disp, int *rank_source, int *rank_dest)

Аргумент direction указывает измерение, в котором осуществляется смещение данных. Измерения маркируются от 0 до ndims-1, где ndims - число размерностей. disp указывает направление и величину смещения. Например, в топологии "линейка" или "кольцо" с N ≥ 4 процессами для процесса с номером 1 при disp = +1 rank_source = 0, а rank_dest = 2; при disp = -1 rank_source = 2, а rank_dest = 0. Для этого же процесса 1 при disp = +2 rank_source = N-1 для "кольца" и MPI_PROC_NULL для "линейки", а rank_dest = 3 для обоих структур; при disp = -2 rank_source = 3 для обоих структур, а rank_dest = N-1 для "кольца" и MPI_PROC_NULL для "линейки".

В зависимости от периодичности декартовой топологии в указанном направлении координат, MPI_CART_SHIFT обеспечивает идентификаторы rank_source и rank_dest для кольцевого или не кольцевого смещения данных. Это имеющие силу входные аргументы к функции MPI_SENDRECV. Ни MPI_CART_SHIFT, ни MPI_SENDRECV не коллективные функции. Не требуется, чтобы все процессы в декартовой решетке одновременно вызвали MPI_CART_SHIFT с теми же самыми direction и disp аргументами, но только тот процесс, который посылает соответственно, получает в последующих запросах к MPI_SENDRECV.

1   2   3   4   5

---

Декартова функция разбиения

MPI_CART_SUB(comm, remain_dims, newcomm)

IN comm communicator для декартовой топологии

IN remain_dims i-й элемент remain_dims определяет

соответствующую i-ю размерность

включаемую в подрешетку (true) или не

включаемую (false)

OUT newcomm communicator созданных подрешеток

int MPI_Cart_sub(MPI_Comm comm, int *remain_dims, MPI_Comm *newcomm)

Если декартова топология была создана функцией MPI_CART_CREATE, то может использоваться функция MPI_CART_SUB для разбиения группы, связанной коммуникатором, на подгруппы, которые формируют декартовы подрешетки меньшей размерности, и строить для каждой такой подгруппы коммуникатор, связанный с подрешеткой декартовой топологии. Этот запрос коллективный.

ПРИМЕР 3.1.

Предположим, что MPI_CART_CREATE(...,comm) определяет (2 х 3 х 4) решетку. Допустим remain_dims =(true, false, true). Тогда запрос к

MPI_CART_SUB(comm, remain_dims, comm_new)

создаст три коммуникатора каждый с восьмью процессами 2 х 4 в декартовой топологии. Если remain_dims =(false, false, true), то запрос к MPI_CART_SUB(comm, remain_dims, comm_new) создаст шесть непересекающихся коммуникаторов, каждый с четырьмя процессами, в одномерной декартовой топологии.

ПРИМЕР 3.2.

…

int rem[3], dims[3], period[3], reord, i, j;

MPI_Comm comm_3D, comm_2D[3], comm_1D[3];

…

MPI_Cart_create(MPI_COMM_WORLD, 3, dims, period, reord, &comm_3D);

…

for(i = 0; i < 3; j++)

{

for(j = 0; j < 3; j++)

rem[j] = (i != j);

MPI_Cart_sub(comm_3D, rem, &comm_2D[i]);

}

for(i = 0; i < 3; j++)

{

for(j = 0; j < 3; j++)

rem[j] = (i == j);

MPI_Cart_sub(comm_3D, rem, &comm_1D[i]);

}

Функции создания топологии графа

Функция построения графа

MPI_GRAPH_CREATE(comm_old, nnodes, index, edges, reorder, comm_graph)

IN comm_old входной коммуникатор

IN nnodes количество узлов в графе

IN index целочисленный массив для описания

узлов графа

IN edges целочисленный массив для описания

ребер графа

IN reorder переупорядочить ранги (true) или нет

(false)

OUT comm_graph коммуникатор с топологией

построенного графа

int MPI_Graph_create(MPI_Comm comm_old, int nnodes, int *index, int *edges, int reorder, MPI_Comm *comm_graph)

MPI_GRAPH_CREATE возвращает новый коммуникатор, к которому присоединена информация топологии графа. Если reorder==false, то ранг каждого процесса в новой группе идентичен ее рангу в старой группе. Иначе, функция может переупорядочивать процессы. Если размер, nnodes, графа меньше чем размер группы comm_old, то некоторые процессы возвращают MPI_COMM_NULL. Запрос ошибочен, если он определяет граф, который является большим, чем размер группы определяемой comm_old. Эта функция коллективная.

---

Три параметра nnodes, index и edges определяют структуру графа. nnodes - число узлов графа. Узлы маркируются от 0 до nnodes-1. i-й элемент массива index хранит общее число соседей первых i узлов графа. Списки соседних узлов 0,1,...,nnodes-1 хранятся в массиве edges. Массив edges - сжатое представление списков ребер. Общее число элементов в index равно nnodes, и общее число элементов в edges равно числу ребер графа. Определения аргументов nnodes, index, и edges иллюстрируются ниже в примере 1.5.

ПРИМЕР 3.3.

Предположим, что имеются четыре компьютера 0, 1, 2, 3 со следующей матрицей смежности:

Компьютер	Соседи
0 1 2 3	1, 3 0 3 0, 2

Тогда, входные аргументы будут иметь следующие значения:

nnodes = 4

index = (2, 3, 4, 6)

edges = (1, 3, 0, 3, 0, 2)

Функции запроса графа

Если топология графа установлена, может быть необходимо запросить информацию относительно топологии. Эти функции даются ниже и все - локальные вызовы.

MPI_GRAPHDIMS_GET(comm, nnodes, nedges)

IN comm коммуникатор группы,

связанной с графом

OUT nnodes количество узлов в графе

OUT nedges количество ребер в графе

int MPI_Graphdims_get(MPI_Comm_comm, int *nnodes, int *nedges)

MPI_GRAPHDIMS_GET(COMM, NNODES, NEDGES, IERROR)

INTEGER COMM, NNODES, NEDGES, IERROR

MPI_GRAPHDIMS_GET возвращает число узлов и число ребер в графе. Число узлов идентично размеру группы, связанному с comm. nnodes и nedges используются, чтобы снабдить массивы надлежащего размера для index и edges, соответственно, в функции MPI_GRAPH_GET. MPI_GRAPHDIMS_GET возвратил бы nnodes = 4 и nedges = 6 в примере 1.5.

MPI_GRAPH_GET(comm, maxindex, maxedges, index, edges)

IN comm коммуникатор группы со

структурой графа

IN maxindex длина вектора index в вызвавшей

программе

IN maxedges длина вектора edges в вызвавшей

программе

OUT index массив чисел, определяющих

узлы графа

OUT edges массив чисел, определяющих узлы

графа

int MPI_Graph_get(MPI_Comm comm, int maxindex, int maxedges, int *index, int *edges)

MPI_GRAPH_GET(COMM, MAXINDEX, MAXEDGES, INDEX, EDGES, IERROR)

INTEGER COMM, MAXINDEX, MAXEDGES, INDEX(*), EDGES(*), IERROR

MPI_GRAPH_GET возвращает index и edges какими они были в MPI_GRAPH_CREATE. maxindex и maxedges по крайней мере такие же как nnodes и nedges, соответственно, какие возвращаются функцией MPI_GRAPHDIMS_GET.

Неблокированные посылающая и получающая функции

Можно улучшить выполнение многих программ, выполняя обмен данными и вычисления с перекрытием, т.е. параллельно. Это особенно хорошо реализуется на системах, где связь может быть выполнена автономно от работы компьютера. Многоподпроцессный режим - один из механизмов для достижения такого перекрытия. В то время как один из подпроцессов блокирован, ожидая завершения связи, другой подпроцесс может выполняться на том же самом процессоре. Этот механизм эффективен, если система поддерживает многоподпроцессный режим.

---

Неблокированные функции

MPI_ISEND(buf, count, datatype, dest, tag, comm, request)

IN buf адрес посылаемого буфера

IN count количество элементов в посылаемом буфере

IN datatype тип элементов в передаваемом буфере

IN dest номер принимающего процессора

IN tag тег передаваемых данных

IN comm имя коммуникатора связи (communicator)

OUT request имя (заголовка) запроса

int MPI_Isend(void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request *request)

Неблокированая передача данных, инициализирует посылающее действие, но не заканчивает его. Функция возвратит управление прежде, чем сообщение скопировано вне посылающегося буфера. Неблокированная посылающая функция указывает, что система может начинать копировать данные вне посылающегося буфера. Посылающий процесс не должен иметь доступ к посылаемому буферу после того, как неблокированное посылающее действие инициировано, до тех пор, пока функция завершения не возвратит управление.

MPI_IRECV(buf, count, datatype, source, tag, comm, request)

OUT buf адрес буфера приема данных

IN count максимальное количество принимаемых элементов

IN datatype тип принимаемых элементов

IN source номер передающего процесса

IN tag тег сообщения

IN comm имя коммуникатора связи (communicator)

OUT request имя (заголовка) запроса

int MPI_Irecv(void* buf, int count, MPI_Datatype datatype, int source, int tag, MPI_Comm comm, MPI_Request *request)

Неблокированый прием данных, инициализирует получающее действие, но не заканчивает его. Функция возвратит управление прежде, чем сообщение записано в буфер приема данных. Неблокированная получающая функция указывает, что система может начинать писать данные буфер приема данных. Приемник не должен иметь доступ к буферу приема после того, как неблокированное получающее действие инициировано, до тех пор, пока функция завершения не возвратит управление.

Эти обе функции размещают данные в системном буфере, и возвращают заголовок этого запроса в request. request используется, чтобы опросить состояние связи.

Функции завершения неблокированных операций

Чтобы закончить неблокированные посылку и получение данных, используются завершающие функции MPI_WAIT и MPI_TEST. Завершение посылающего процесса указывает, что он теперь свободен к доступу посылающегося буфера. Завершение получающего процесса указывает, что буфер приема данных содержит сообщение, приемник свободен к его доступу.

---

Смотрите также файлы

• марбек дукеев атындаы алматы энергетика жне байланыс университеті.docx

• Пні физика Мектеп 47 жалпы орта білім беретін мектебі.docx

• Закон Кулона Электрически изолированная система тел Способы электризации Закон дискретности электрического заряда.docx

• 10 4 кездейсо шаманы не екенін тсіну жне кездейсо шамалара мысалдар келтіру.docx

• Задача Решите задачу.docx