在上一篇中我們介紹了 mpi4py 中非重復非阻塞緩沖通信模式悔政,下面我們將介紹非重復非阻塞就緒通信清笨。
非重復非阻塞的就緒通信模式是與阻塞的就緒通信模式相對應的窜锯,其通信方法(MPI.Comm 類的方法)接口有一個前綴修飾 I/i溶其,注意:在就緒通信模式中只有只有以大寫字母開頭的 Irsend,沒有以小寫字母開頭的 irsend懊悯。
Irsend(self, buf, int dest, int tag=0)
Irecv(self, buf, int source=ANY_SOURCE, int tag=ANY_TAG)
這些方法調(diào)用中的參數(shù)是與阻塞標準通信模式的方法調(diào)用參數(shù)一樣的蜓谋。
需要注意的是,上面雖然給出的是非阻塞的發(fā)送和非阻塞的接收方法定枷,但非阻塞發(fā)送可與阻塞接收相匹配孤澎,反之,阻塞發(fā)送也可與非阻塞接收相匹配欠窒。
下面給出非重復非阻塞就緒通信的使用例程:
# Irsend_Irecv.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.Irsend(send_buf, dest=1, tag=11)
send_req.Wait()
print 'process %d sends %s' % (rank, send_buf)
elif rank == 1:
recv_req = comm.Irecv(recv_buf, source=0, tag=11)
recv_req.Wait()
print 'process %d receives %s' % (rank, recv_buf)
運行結果如下:
$ mpiexec -n 2 python Irsend_Irecv.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 中非重復非阻塞就緒通信模式荐虐,在下一篇中我們將介紹非重復非阻塞同步通信七兜。