在上一篇中我们介绍了 mpi4py 中可重复非阻塞同步通信模式，下面我们将介绍组合发送接收操作。
组合发送接收操作比较适合接力通信的场合。在使用组合发送接收的时候要注意合理安排相关进程之间发送/接收操作的顺序，以避免死锁。
组合通信的发送操作，可被任何接收操作匹配，反之，组合通信的接收操作也可匹配任何其它类型的发送动作。
组合发送接收通信方法（MPI.Comm 类的方法）接口如下：
sendrecv(self, sendobj, int dest, int sendtag=0, recvbuf=None, int source=ANY_SOURCE, int recvtag=ANY_TAG, Status status=None)
Sendrecv(self, sendbuf, int dest, int sendtag=0, recvbuf=None, int source=ANY_SOURCE, int recvtag=ANY_TAG, Status status=None)
这些方法调用中的参数是与阻塞标准通信模式的方法调用参数一样的。
下面给出组合发送接收通信的使用例程：
# sendrecv.py
from mpi4py import MPI
comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()
tag = 123
left = rank - 1 if rank >=1 else size - 1
right = rank + 1 if rank < size - 1 else 0
send_obj = {'obj': rank}
recv_obj = comm.sendrecv(send_obj, dest=right, sendtag=tag, source=left, recvtag=tag)
print 'process %d sends %s' % (rank, send_obj)
print 'process %d receives %s' % (rank, recv_obj)
运行结果如下：
$ mpiexec -n 4 python sendrecv.py
process 0 sends {'obj': 0}
process 0 receives {'obj': 3}
process 1 sends {'obj': 1}
process 1 receives {'obj': 0}
process 2 sends {'obj': 2}
process 2 receives {'obj': 1}
process 3 sends {'obj': 3}
process 3 receives {'obj': 2}
# Sendrecv.py
import numpy as np
from mpi4py import MPI
comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()
tag = 123
left = rank - 1 if rank >=1 else size - 1
right = rank + 1 if rank < size - 1 else 0
count = 10
send_buf = np.arange(count, dtype='i') + 10 * rank
recv_buf = np.empty(count, dtype='i')
comm.Sendrecv(send_buf, dest=right, sendtag=tag, recvbuf=recv_buf, source=left, recvtag=tag)
print 'process %d sends %s' % (rank, send_buf)
print 'process %d receives %s' % (rank, recv_buf)
运行结果如下：
$ mpiexec -n 4 python Sendrecv.py
process 0 sends [0 1 2 3 4 5 6 7 8 9]
process 0 receives [30 31 32 33 34 35 36 37 38 39]
process 2 sends [20 21 22 23 24 25 26 27 28 29]
process 2 receives [10 11 12 13 14 15 16 17 18 19]
process 3 sends [30 31 32 33 34 35 36 37 38 39]
process 3 receives [20 21 22 23 24 25 26 27 28 29]
process 1 sends [10 11 12 13 14 15 16 17 18 19]
process 1 receives [0 1 2 3 4 5 6 7 8 9]
上面的例程通过组合发送接收操作实现了多个进程间的循环收发通信。
组合发送操作方法 Sendrecv 还有一个变化的形式 Sendrecv_replace，它会复用发送缓冲区，即发送消息缓冲区同时也作为接收消息缓冲区，原有的发送消息缓冲区将被覆盖，其方法（MPI.Comm 类的方法）接口如下：
Sendrecv_replace(self, buf, int dest, int sendtag=0, int source=ANY_SOURCE, int recvtag=ANY_TAG, Status status=None)
下面给出其使用例程：
# Sendrecv_replace.py
import numpy as np
from mpi4py import MPI
comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()
tag = 123
left = rank - 1 if rank >=1 else size - 1
right = rank + 1 if rank < size - 1 else 0
count = 10
send_buf = np.arange(count, dtype='i') + 10 * rank
print 'process %d sends %s' % (rank, send_buf)
comm.Sendrecv_replace(send_buf, dest=right, sendtag=tag, source=left, recvtag=tag)
print 'process %d receives %s' % (rank, send_buf)
运行结果如下：
$ mpiexec -n 4 python Sendrecv_replace.py
process 3 sends [30 31 32 33 34 35 36 37 38 39]
process 1 sends [10 11 12 13 14 15 16 17 18 19]
process 1 receives [0 1 2 3 4 5 6 7 8 9]
process 0 sends [0 1 2 3 4 5 6 7 8 9]
process 0 receives [30 31 32 33 34 35 36 37 38 39]
process 3 receives [20 21 22 23 24 25 26 27 28 29]
process 2 sends [20 21 22 23 24 25 26 27 28 29]
process 2 receives [10 11 12 13 14 15 16 17 18 19]
上面我们介绍了 mpi4py 中组合发送接收通信方法，至此我们就对 mpi4py 中提供的各种点到点通信方法都做了一个简略的介绍，并给出了简短的使用例程。在下一篇中我们将对点到点通信做一个小结。
网友评论