Я порождаю процессы mpi с
# Master side
comm = MPI.COMM_SELF.Spawn(sys.executable, ["worker.py"], maxprocs=2)
на главной стороне и
# Worker side
comm = MPI.Comm.Get_parent()
workerComm = MPI.COMM_WORLD
на рабочей стороне.Я могу отправлять данные туда и обратно, используя двухточечную связь, а также коллективную связь.Я могу создавать группы на рабочей стороне, используя workerComm с
newGroup = workerComm.group.Incl([0])
newComm = workerComm.Create_group(newGroup)
Но как можно создать группу с master и worker * 1014?* Как я могу использовать коллективные коммуникации со стороны master только с подмножеством работников?