【文章內(nèi)容簡介】 mpicc –o hello1 [dair@node01 ~]$ mpirun np 4 hello1 I am 0 of 4 I am 1 of 4 I am 2 of 4 I am 3 of 4 [dair@node01 ~]$ 計算機打印字符 我們輸入的命令 2022年 2月 23/55 ? :寫 MPI并行通信程序 Send和 Recv 進程 0rank=0..Send()...進程 1rank=1進程 2rank=2進程 3rank=3..Send().....Send().....Recv()...Greeting執(zhí)行過程 2022年 2月 24/55 有消息傳遞 greetings(c) include include main(int argc, char* argv[]) { int numprocs, myid, source。 MPI_Status status。 char message[100]。 MPI_Init(amp。argc, amp。argv)。 MPI_Comm_rank(MPI_COMM_WORLD, amp。myid)。 MPI_Comm_size(MPI_COMM_WORLD, amp。numprocs)。 2022年 2月 25/55 有消息傳遞 greetings(c) if (myid != 0) { strcpy(message, Hello World!)。 MPI_Send(message,strlen(message)+1, MPI_CHAR, 0,99, MPI_COMM_WORLD)。 } else {/* myid == 0 */ for (source = 1。 source numprocs。 source++) { MPI_Recv(message, 100, MPI_CHAR, source, 99, MPI_COMM_WORLD, amp。status)。 printf(%s\n, message)。 } } MPI_Finalize()。 } /* end main */ 2022年 2月 26/55 解剖 greetings程序 頭文件 : int MPI_Init(int *argc, char ***argv) 啟動 MPI環(huán)境 ,標志并行代碼的開始 . 并行代碼之前 ,第一個 mpi函數(shù) (除 MPI_Initialize()外 ). 要求 main必須帶參數(shù)運行 ,否則出錯 . 通信域 (通信空間 ): MPI_COMM_WORLD： 一個通信空間是一個進程組和一個上下文的組合 .上下文可看作為組的超級標簽 ,用于區(qū)分不同的通信域 . 在執(zhí)行函數(shù) MPI_Init之后 ,一個 MPI程序的所有進程形成一個缺省的組 ,這個組的通信域即被寫作 MPI_COMM_WORLD. 該參數(shù)是 MPI通信操作函數(shù)中必不可少的參數(shù) ,用于限定參加通信的進程的范圍 . 2022年 2月 27/55 解剖 greetings程序 int MPI_Comm_size ( MPI_Comm m, int *size ) 獲得通信空間 m中規(guī)定的組包含的進程的數(shù)量 . 指定一個 municator,也指定了一組共享該空間的進程 , 這些進程組成該 municator的 group. int MPI_Comm_rank ( MPI_Comm m, int *rank ) 得到本進程在通信空間中的 rank值 ,即在組中的邏輯編號 (從 0開始 ). int MPI_Finalize() 標志并行代碼的結束 ,結束除主進程外其它進程 . 之后串行代碼仍可在主進程 (rank = 0)上運行 (如果必須 ). 2022年 2月 28/55 講座內(nèi)容提示 基本的 MPI 基本概念 點到點通信 (Point to point) MPI中 API的主要內(nèi)容，為 MPI最基本，最重要的內(nèi)容 MPI程序的編譯和運行 深入 MPI 用戶自定義 (/派生 )數(shù)據(jù)類型 (Userdefined(Derived) data type) 事實上 MPI的所有數(shù)據(jù)類型均為 MPI自定義類型 支持異構系統(tǒng) 允許消息來自不連續(xù)的或類型不一致的存儲區(qū) (結構 ,數(shù)組散元 ) 集合通信 (Collective) 數(shù)據(jù)移動，數(shù)據(jù)聚集，同步 基于 point to point 構建 MPI環(huán)境管理函數(shù) 組 ,上下文和通信空間 /通信域的管理 實例 2022年 2月 29/55 Point to Point通信 單個進程對單個進程的通信 ,重要且復雜 術語 Blocking(阻塞 ) :一個例程須等待操作完成才返回 ,返回后用戶可以重新使用調用中所占用的資源 . Nonblocking(非阻塞 ):一個例程不必等待操作完成便可返回 ,但這并不意味著所占用的資源可被重用 . Local(本地 ):過程的完成僅依賴于本地正在執(zhí)行的進程。 Nonlocal(非本地 ):如果過程的完成要求其他進程的 MPI 過程完成。 2022年 2月 30/55 Blocking Send int MPI_Send(void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm m)。 IN buf 發(fā)送緩沖區(qū)的起始地址 IN count 要發(fā)送信息的 元素 個數(shù) IN datatype 發(fā)送信息的數(shù)據(jù)類型 IN dest 目標進程的 rank值 IN tag 消息標簽 IN m 通信域 2022年 2月 31/55 Blocking Receive int MPI_Recv(void* buf, int count, MPI_Datatype data