к.ф.-м.н., н.с. лаборатории Параллельных информационных технологий НИВЦ МГУ
- Главная
- Разное
- Дизайн
- Бизнес и предпринимательство
- Аналитика
- Образование
- Развлечения
- Красота и здоровье
- Финансы
- Государство
- Путешествия
- Спорт
- Недвижимость
- Армия
- Графика
- Культурология
- Еда и кулинария
- Лингвистика
- Английский язык
- Астрономия
- Алгебра
- Биология
- География
- Детские презентации
- Информатика
- История
- Литература
- Маркетинг
- Математика
- Медицина
- Менеджмент
- Музыка
- МХК
- Немецкий язык
- ОБЖ
- Обществознание
- Окружающий мир
- Педагогика
- Русский язык
- Технология
- Физика
- Философия
- Химия
- Шаблоны, картинки для презентаций
- Экология
- Экономика
- Юриспруденция
Введение в параллельные вычисления. Технология программирования MPI (день четвертый) презентация
Содержание
- 1. Введение в параллельные вычисления. Технология программирования MPI (день четвертый)
- 2. MPI MPI_SEND_INIT(BUF, COUNT, DATATYPE, DEST, MSGTAG, COMM,
- 3. MPI Модификации функции MPI_SEND_INIT: MPI_BSEND_INIT — формирование запроса
- 4. MPI MPI_RECV_INIT(BUF, COUNT, DATATYPE, SOURCE, MSGTAG, COMM,
- 5. MPI MPI_START(REQUEST, IERR) INTEGER REQUEST, IERR Инициализация
- 6. MPI MPI_STARTALL(COUNT, REQUESTS, IERR) INTEGER COUNT, REQUESTS,
- 7. MPI Сообщение, отправленное при помощи отложенного запроса,
- 8. MPI MPI_REQUEST_FREE(REQUEST, IERR) INTEGER REQUEST, IERR Удаляет
- 9. MPI prev = rank - 1 next
- 10. MPI call MPI_SEND_INIT(sbuf(2), 1,
- 11. MPI Тупиковые ситуации (deadlock): процесс 0: RECV(1)
- 12. MPI Разрешение тупиковых ситуаций: 1. процесс 0:
- 13. MPI MPI_SENDRECV(SBUF, SCOUNT, STYPE, DEST, STAG, RBUF,
- 14. MPI Совмещенные прием и передача сообщений с
- 15. MPI MPI_SENDRECV_REPLACE(BUF, COUNT, DATATYPE, DEST, STAG, SOURCE,
- 16. MPI prev = rank - 1 next
- 17. MPI MPI_BARRIER(COMM, IERR) INTEGER COMM, IERR Работа
- 18. MPI Специальное значение MPI_PROC_NULL для несуществующего процесса.
- 19. MPI MPI_GET_PROCESSOR_NAME(NAME, LEN, IERR) CHARACTER*(*) NAME INTEGER
MPI MPI_SEND_INIT(BUF, COUNT, DATATYPE, DEST, MSGTAG, COMM, REQUEST, IERR) BUF(*) INTEGER COUNT, DATATYPE, DEST, MSGTAG, COMM, REQUEST, IERR Формирование отложенного запроса на посылку сообщения. Сама операция пересылки не начинается!
Слайд 1Введение в параллельные вычисления. Технология программирования MPI (день четвертый)
Антонов Александр Сергеевич,
Слайд 2MPI
MPI_SEND_INIT(BUF, COUNT, DATATYPE, DEST, MSGTAG, COMM, REQUEST, IERR)
BUF(*)
INTEGER COUNT, DATATYPE,
DEST, MSGTAG, COMM, REQUEST, IERR
Формирование отложенного запроса на посылку сообщения. Сама операция пересылки не начинается!
Формирование отложенного запроса на посылку сообщения. Сама операция пересылки не начинается!
Слайд 3MPI
Модификации функции MPI_SEND_INIT:
MPI_BSEND_INIT — формирование запроса на передачу сообщения с буферизацией.
MPI_SSEND_INIT —
формирование запроса на передачу сообщения с синхронизацией.
MPI_RSEND_INIT — формирование запроса на передачу сообщения по готовности.
MPI_RSEND_INIT — формирование запроса на передачу сообщения по готовности.
Слайд 4MPI
MPI_RECV_INIT(BUF, COUNT, DATATYPE, SOURCE, MSGTAG, COMM, REQUEST, IERR)
BUF(*)
INTEGER COUNT, DATATYPE,
SOURCE, MSGTAG, COMM, REQUEST, IERR
Формирование отложенного запроса на прием сообщения. Сама операция приема не начинается!
Формирование отложенного запроса на прием сообщения. Сама операция приема не начинается!
Слайд 5MPI
MPI_START(REQUEST, IERR)
INTEGER REQUEST, IERR
Инициализация отложенного запроса на выполнение операции обмена, соответствующей
значению параметра REQUEST. Операция запускается как неблокирующая.
Слайд 6MPI
MPI_STARTALL(COUNT, REQUESTS, IERR)
INTEGER COUNT, REQUESTS, IERR
Инициализация COUNT отложенных запросов на выполнение
операций обмена, соответствующих значениям первых COUNT элементов массива REQUESTS. Операции запускаются как неблокирующие.
Слайд 7MPI
Сообщение, отправленное при помощи отложенного запроса, может быть принято любой из
процедур MPI_RECV и MPI_IRECV, и наоборот.
По завершении отложенного запроса значение параметра REQUEST (REQUESTS) сохраняется и может использоваться в дальнейшем!
По завершении отложенного запроса значение параметра REQUEST (REQUESTS) сохраняется и может использоваться в дальнейшем!
Слайд 8MPI
MPI_REQUEST_FREE(REQUEST, IERR)
INTEGER REQUEST, IERR
Удаляет структуры данных, связанные с параметром REQUEST. REQUEST
устанавливается в значение MPI_REQUEST_NULL. Если операция, связанная с этим запросом, уже выполняется, то она завершится.
Слайд 9MPI
prev = rank - 1
next = rank + 1
if (rank .eq.
0) prev = numtasks - 1
if (rank .eq. numtasks - 1) next = 0
call MPI_RECV_INIT(rbuf(1), 1,
& MPI_REAL, prev, tag1,
& MPI_COMM_WORLD, reqs(1), ierr)
call MPI_RECV_INIT(rbuf(2), 1,
& MPI_REAL, next, tag2,
& MPI_COMM_WORLD, reqs(2), ierr)
call MPI_SEND_INIT(sbuf(1), 1,
& MPI_REAL, prev, tag2,
& MPI_COMM_WORLD, reqs(3), ierr)
if (rank .eq. numtasks - 1) next = 0
call MPI_RECV_INIT(rbuf(1), 1,
& MPI_REAL, prev, tag1,
& MPI_COMM_WORLD, reqs(1), ierr)
call MPI_RECV_INIT(rbuf(2), 1,
& MPI_REAL, next, tag2,
& MPI_COMM_WORLD, reqs(2), ierr)
call MPI_SEND_INIT(sbuf(1), 1,
& MPI_REAL, prev, tag2,
& MPI_COMM_WORLD, reqs(3), ierr)
Слайд 10MPI
call MPI_SEND_INIT(sbuf(2), 1,
& MPI_REAL, next, tag1,
& MPI_COMM_WORLD, reqs(4), ierr)
do i=...
sbuf(1)=...
sbuf(2)=...
call MPI_STARTALL(4, reqs, ierr)
...
call MPI_WAITALL(4, reqs, stats,
& ierr);
...
end do
do i=...
sbuf(1)=...
sbuf(2)=...
call MPI_STARTALL(4, reqs, ierr)
...
call MPI_WAITALL(4, reqs, stats,
& ierr);
...
end do
Слайд 11MPI
Тупиковые ситуации (deadlock):
процесс 0:
RECV(1)
SEND(1)
процесс 1:
RECV(0)
SEND(0)
процесс 0:
SEND(1)
RECV(1)
процесс 1:
SEND(0)
RECV(0)
Слайд 12MPI
Разрешение тупиковых ситуаций:
1.
процесс 0:
SEND(1)
RECV(1)
процесс 1:
RECV(0)
SEND(0)
2. Использование неблокирующих операций
3. Использование функции MPI_SENDRECV
Слайд 13MPI
MPI_SENDRECV(SBUF, SCOUNT, STYPE, DEST, STAG, RBUF, RCOUNT, RTYPE, SOURCE, RTAG, COMM,
STATUS, IERR)
SBUF(*), RBUF(*)
INTEGER SCOUNT, STYPE, DEST, STAG, RCOUNT, RTYPE, SOURCE, RTAG, COMM, STATUS(MPI_STATUS_SIZE), IERR
INTEGER SCOUNT, STYPE, DEST, STAG, RCOUNT, RTYPE, SOURCE, RTAG, COMM, STATUS(MPI_STATUS_SIZE), IERR
Слайд 14MPI
Совмещенные прием и передача сообщений с блокировкой. Буферы передачи и приема
не должны пересекаться. Тупиковой ситуации не возникает!
Сообщение, отправленное операцией MPI_SENDRECV, может быть принято обычным образом, и операция MPI_SENDRECV может принять сообщение, отправленное обычной операцией.
Сообщение, отправленное операцией MPI_SENDRECV, может быть принято обычным образом, и операция MPI_SENDRECV может принять сообщение, отправленное обычной операцией.
Слайд 15MPI
MPI_SENDRECV_REPLACE(BUF, COUNT, DATATYPE, DEST, STAG, SOURCE, RTAG, COMM, STATUS, IERR)
BUF(*)
INTEGER
COUNT, DATATYPE, DEST, STAG, SOURCE, RTAG, COMM, STATUS(MPI_STATUS_SIZE), IERR
Совмещенные прием и передача сообщений с блокировкой через общий буфер BUF.
Совмещенные прием и передача сообщений с блокировкой через общий буфер BUF.
Слайд 16MPI
prev = rank - 1
next = rank + 1
if (rank .eq.
0) prev = numtasks - 1
if (rank .eq. numtasks - 1) next = 0
call MPI_SENDRECV(
& sbuf(1), 1, MPI_REAL, prev, tag2,
& rbuf(1), 1, MPI_REAL, next, tag2,
& MPI_COMM_WORLD, status1, ierr)
call MPI_SENDRECV(
& sbuf(2), 1, MPI_REAL, next, tag1,
& rbuf(2), 1, MPI_REAL, prev, tag1,
& MPI_COMM_WORLD, status1, ierr)
if (rank .eq. numtasks - 1) next = 0
call MPI_SENDRECV(
& sbuf(1), 1, MPI_REAL, prev, tag2,
& rbuf(1), 1, MPI_REAL, next, tag2,
& MPI_COMM_WORLD, status1, ierr)
call MPI_SENDRECV(
& sbuf(2), 1, MPI_REAL, next, tag1,
& rbuf(2), 1, MPI_REAL, prev, tag1,
& MPI_COMM_WORLD, status1, ierr)
Слайд 17MPI
MPI_BARRIER(COMM, IERR)
INTEGER COMM, IERR
Работа процессов блокируется до тех пор, пока все
оставшиеся процессы коммуникатора COMM не выполнят эту процедуру. Все процессы должны вызвать MPI_BARRIER, хотя реально исполненные вызовы различными процессами коммуникатора могут быть расположены в разных местах программы.
Слайд 18MPI
Специальное значение MPI_PROC_NULL для несуществующего процесса. Операции с таким процессом завершаются
немедленно с кодом завершения MPI_SUCCESS.
next=rank+1
if(rank .EQ. size-1) next=MPI_PROC_NULL
call MPI_SEND (buf, 1, MPI_REAL, next,
& tag, MPI_COMM_WORLD, ierr)
next=rank+1
if(rank .EQ. size-1) next=MPI_PROC_NULL
call MPI_SEND (buf, 1, MPI_REAL, next,
& tag, MPI_COMM_WORLD, ierr)
Слайд 19MPI
MPI_GET_PROCESSOR_NAME(NAME, LEN, IERR)
CHARACTER*(*) NAME
INTEGER LEN, IERR
Функция возвращает в строке NAME имя
узла, на котором запущен вызвавший процесс. В переменной LEN возвращается количество символов в имени, не превышающее константы MPI_MAX_PROCESSOR_NAME.
