exchanger.py 文件源码

def do_sendrecv(comm, glist, wlist, dest):
    for gs, ws in zip(glist, wlist):
        g = gs.container.value
        w = ws.container.value
        g.sync()
        w.sync()
        comm.Sendrecv(sendbuf=[bufint(g), MPI.FLOAT], dest=dest,
                      recvbuf=[bufint(w), MPI.FLOAT], source=dest)