mpi4py 点到点通信之可重复的非阻塞就绪通信

2024年2月5日 222次阅读 来源: 自可乐

在上一篇中我们介绍了 mpi4py 中可重复非阻塞缓冲通信模式，下面我们将介绍可重复非阻塞就绪通信。

可重复非阻塞的就绪通信模式是与阻塞的就绪通信模式相对应的，其通信方法（MPI.Comm 类的方法）接口如下：

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

这些方法调用中的参数是与阻塞标准通信模式的方法调用参数一样的。

需要注意的是，上面虽然给出的是可重复非阻塞的发送和可重复非阻塞的接收方法，但实际上可重复非阻塞发送可与任何接收动作（阻塞接收，非重复非阻塞接收）匹配，反之，可重复非阻塞接收也可与任何发送动作（阻塞发送，非重复非阻塞发送）匹配。

下面给出可重复非阻塞就绪通信的使用例程：

# 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]

就绪通信模式要求对方的接收操作启动并准备就绪时，才可发送数据。在实际应用中，如果采用就绪的通信模式，应该确保对方的接收操作启动并准备就绪后再发送数据。

上面我们介绍了 mpi4py 中可重复非阻塞就绪通信模式，在下一篇中我们将介绍可重复非阻塞同步通信。

    原文作者：自可乐
    原文地址: https://www.jianshu.com/p/b977984bb03f
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞