为什么此mpi4py代码不能正确发送?

2024-04-26 23:18:08 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试制作一个多级多进程区块链,但我的程序的基础,即从一个进程到另一个进程发送包,是行不通的

from mpi4py import MPI
import numpy as np
import sys
comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size=comm.size
Nprimos=int(sys.argv[1])
k=int(sys.argv[2])
if rank==0:
    for i in range(1,size):
        print("Send to: ",i)
        if i%3!=0:
            print("in")
            comm.send(10,Destino=i,tag=1)
            print("sent")
            print("Package sent to ",i)
if rank%3!=0:
    print(rank)
    seccion=comm.recv(source=0,tag=1)
    print(seccion)

根进程从不发送数据


Tags: toinimportsizeif进程tagsys