Возможность запуска новых процессов во время выполнения 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.