獲取當前時間
在插入MPI提供的頭文件后,可以獲得獲取時間的函數。
double MPI_Wtime(void) 取得當前時間, 計時的精度由 double MPI_Wtick(void) 取得
作為對比,一般在C/C++中, 插入time.h,通過 clock_t clock(void) 取得當前時間, 計時的精度由常數 CLOCKS_PER_SEC 定義。
點到點通信函數
進程間的通信需要通過一個通信器來完成。MPI 環境在初始化時會自動創建兩個通信器,一個稱為 MPI_COMM_WORLD,它包含程序中的所有進程,另一個稱為 MPI_COMM_SELF,它是每個進程獨自構成的、僅包含自己的通信器。MPI 系統提供了一個特殊進程號 MPI_PROC_NULL,它代表空進程 (不存在的進程),與 MPI_PROC_NULL 進行通信相當於一個空操 作,對程序的運行沒有任何影響。
使用MPI_Barrier(communicator)來完成同步
使用MPI_Send(message, size, data_type, dest_id, tag, communicator) 來把數據message封裝起來成為真正的消息結構,向進程號為dest_id的進程發送數據,是否要先把消息存入緩沖區根據默認緩沖區的大小確定。
使用MPI_Bsend(message_data, size, data_type, dest_id, tag, communicator) 來發送數據,需要預先注冊一個緩沖區,並調用MPI_Buffer_attach(buffer, buf_size)來供MPI環境使用
使用MPI_Buffer_attach(buffer, size)來把緩沖區buffer提交給MPI環境,其中buffer是通過malloc分配的內存塊。
使用MPI_Buffer_detach(&buffer,&size)來確保傳輸的完成,盡量把detach和attach函數配對使用,正如盡可能同時使用malloc和free,同時使用Init和Finalize,防止遺漏!
使用MPI_Pack_size(size, data_type, communicator, &pack_size)來獲取包裝特定類型的數據所需要的緩沖區大小(還沒有計入頭部,所以真正緩沖區大小 buf_size = MPI_BSEND_OVERHEAD + pack_size,如果有多份數據發送,則buf_size還要疊加)。
使用MPI_Recv(message, size, data_type, src_id, tag, communicator, status)來接收數據,把已經到達接收緩沖區的數據解析到message數組中,只有全部數據都解析出來時,函數才返回。
tips:除了上述兩種發送模式外,還有就緒通信MPI_Rsend()和同步通信MPI_Ssend(),參數都是一致的,函數的區別在於,如果已經保證接收動作在發送動作之前啟動了(可以利用MPI_Barrier函數做到這一點),那么就可以使用MPI_Rsend()提高效率;如果需要保證接收動作發生后,發送動作才能返回,那么就使用MPI_Ssend()
tips:上面都是阻塞通信的方式,也就是調用這些函數的時候進程可能會阻塞。可以使用別的通信模式,或者使用多線程來改變這一點。
集合通信
MPI_Bcast廣播,使得數據有p份拷貝
MPI_Scatter散發,每份數據只拷貝一次
MPI_Gather收集,每份數據只拷貝一次
MPI_Reduce歸約
以后如果需要用到再寫吧。
數據類型和預定義的量
用於作為參數的數據類型 MPI_INT, MPI_DOUBLE, MPI_CHAR, MPI_Status
預定義的量 MPI_STATURS_IGNORE, MPI_ANY_SOURCE, MPI_ANY_TAG
初始化與結束
使用MPI_Init(&argc, &argv)來初始化MPI環境,可能是一些全局變量的初始化。
使用MPI_Comm_rank(communicator, &myid)來獲取當前進程在通信器中具有的進程號。
使用MPI_Comm_size(communicator, &numprocs)來獲取通信器中包含的進程數目。
使用MPI_Finalize()來結束並行編程環境。之后我們就可以創建新的MPI編程環境了。