mpi4py 點到點通信之可重復的非阻塞就緒通信

上一篇中我們介紹了 mpi4py 中可重復非阻塞緩沖通信模式,下面我們將介紹可重復非阻塞就緒通信。

可重復非阻塞的就緒通信模式是與阻塞的就緒通信模式相對應的,其通信方法(MPI.Comm 類的方法)接口如下:

Rsend_init(self, buf, int dest, int tag=0)
Recv_init(self, buf, int source=ANY_SOURCE, int tag=ANY_TAG)

這些方法調用中的參數(shù)是與阻塞標準通信模式的方法調用參數(shù)一樣的。

需要注意的是,上面雖然給出的是可重復非阻塞的發(fā)送和可重復非阻塞的接收方法,但實際上可重復非阻塞發(fā)送可與任何接收動作(阻塞接收,非重復非阻塞接收)匹配,反之,可重復非阻塞接收也可與任何發(fā)送動作(阻塞發(fā)送,非重復非阻塞發(fā)送)匹配。

下面給出可重復非阻塞就緒通信的使用例程:

# Rsend_init_Recv_init.py

import numpy as np
from mpi4py import MPI


comm = MPI.COMM_WORLD
rank = comm.Get_rank()

count = 10
send_buf = np.arange(count, dtype='i')
recv_buf = np.empty(count, dtype='i')

if rank == 0:
    send_req = comm.Rsend_init(send_buf, dest=1, tag=11)
    send_req.Start()
    send_req.Wait()
    print 'process %d sends %s' % (rank, send_buf)
elif rank == 1:
    recv_req = comm.Recv_init(recv_buf, source=0, tag=11)
    recv_req.Start()
    recv_req.Wait()
    print 'process %d receives %s' % (rank, recv_buf)

運行結果如下:

$ mpiexec -n 2 python Rsend_init_Recv_init.py
process 0 sends [0 1 2 3 4 5 6 7 8 9]
process 1 receives [0 1 2 3 4 5 6 7 8 9]

就緒通信模式要求對方的接收操作啟動并準備就緒時,才可發(fā)送數(shù)據(jù)。在實際應用中,如果采用就緒的通信模式,應該確保對方的接收操作啟動并準備就緒后再發(fā)送數(shù)據(jù)。

上面我們介紹了 mpi4py 中可重復非阻塞就緒通信模式,在下一篇中我們將介紹可重復非阻塞同步通信。

最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容