Возможность запуска новых процессов во время выполнения MPI-программы

В MPI-1 параллельная программа запускается в определённом и фиксированном количестве процессов. Это не позволяет приложению, например, "подстраиваться" под изменяющуюся трудоёмкость расчёта. В то же время такой инструмент параллельного программирования как PVM поддерживает возможность динамического изменения числа процессов параллельного приложения. Эта возможность появилась в MPI-2.

Дополнительный процесс (несколько процессов) может быть запущен во время выполнения программы. Процесс может быть также остановлен.

Запуск одного процесса

int MPI_Comm_spawn(char *command, char *argv[], int maxprocs, MPI_Info info,

int root, MPI_Comm comm, MPI_Comm *intercomm, int array_of_errcodes[])

MPI_Comm_spawn(command, argv, maxprocs, info, root, comm, intercomm, array_of_errcodes, ierror)

Входные параметры:

• command - командная строка запуска процесса;
• argv - аргументы командной строки запуска процесса;
• maxprocs - максимальное количество запускаемых процессов;
• info - указывает системе как и где запускается процесс;
• root - ранг главного процесса.

Выходные параметры:

• intercomm - интеркоммуникатор между исходной группой процессов и вновь запущенными процессами;
• array_of_errcodes - коды завершения для запущенных процессов.

При запуске группы процессов для них создаётся собственный коммуникатор MPI_COMM_WORLD, отличный от такого же для родительских процессов. Это коллективная операция. Она завершается после того, как во всех дочерних процессах состоится вызов MPI_Init. Завершение данного вызова в родительском процессе не означает, что в дочерних процессах завершены все вызовы MPI_Init.

Интеркоммуникатор intercomm содержит родительский процесс в локальной группе и дочерние процессы.

Командная строка запуска дочернего процесса представляет собой строку, содержащую имя исполняемого файла.

Дочерний процесс обязательно должен вызывать MPI_Init, иначе результат не определён.

Аргумент argv является массивом строковых значений, представляющих аргументы запускаемых программ.

При вызове MPI_Comm_spawn предпринимается попытка запустить maxprocs процессов. Если какой-то процесс не может быть запущен, возвращается значениеMPI_ERR_SPAWN.

Аргумент info создаётся вызовом специальной подпрограммы MPI_Info_create.

В том случае, когда необходимо запустить несколько разных исполняемых файлов или один файл,но с разными параметрами, можно использовать подпрограммуMPI_Comm_spawn_multiple.

Опуская подробное описание её параметров, приведём интерфейс:

Запуск нескольких процессов

int MPI_Comm_spawn_multiple(int count, char *array_of_commands[], char **array_of_argv[],

int array_of_maxprocs[], MPI_Info array_of_info[], int root,

MPI_Comm comm, MPI_Comm *intercomm, int array_of_errcodes[])

MPI Comm_spawn_multiple(count, array_of_commands, array_of_argv,

array_of_ maxprocs, array_of_info, root, comm, intercomm, array_of_errcodes, ierror)

Подпрограмма MPI_Get_parent возвращает родительский интеркоммуникатор вызывающего процесса:

Определение родительского интеркоммуникатора

int MPI_Comm_get_parent(MPI_Comm *parent)

MPI_Comm_get_parent(parent, ierr)

Если данный процесс не является дочерним по отношению к какому-либо другому процессу, возвращается значение "пустого" коммуникатора MPI_COMM_NULL.

Дата добавления: 2014-01-07