在上一篇中我們介紹了 mpi4py 中可重復(fù)非阻塞緩沖通信模式，下面我們將介紹可重復(fù)非阻塞就緒通信。
可重復(fù)非阻塞的就緒通信模式是與阻塞的就緒通信模式相對(duì)應(yīng)的涝动，其通信方法（MPI.Comm 類的方法）接口如下：
Rsend_init(self, buf, int dest, int tag=0)
Recv_init(self, buf, int source=ANY_SOURCE, int tag=ANY_TAG)
這些方法調(diào)用中的參數(shù)是與阻塞標(biāo)準(zhǔn)通信模式的方法調(diào)用參數(shù)一樣的。
需要注意的是，上面雖然給出的是可重復(fù)非阻塞的發(fā)送和可重復(fù)非阻塞的接收方法计雌，但實(shí)際上可重復(fù)非阻塞發(fā)送可與任何接收動(dòng)作（阻塞接收，非重復(fù)非阻塞接收）匹配玫霎，反之凿滤，可重復(fù)非阻塞接收也可與任何發(fā)送動(dòng)作（阻塞發(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)
運(yùn)行結(jié)果如下：
$ 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]
就緒通信模式要求對(duì)方的接收操作啟動(dòng)并準(zhǔn)備就緒時(shí)翁脆，才可發(fā)送數(shù)據(jù)眷蚓。在實(shí)際應(yīng)用中，如果采用就緒的通信模式鹃祖，應(yīng)該確保對(duì)方的接收操作啟動(dòng)并準(zhǔn)備就緒后再發(fā)送數(shù)據(jù)溪椎。
上面我們介紹了 mpi4py 中可重復(fù)非阻塞就緒通信模式，在下一篇中我們將介紹可重復(fù)非阻塞同步通信恬口。
