mpi4py返回排名差异 | mpi4py返回排名差异

本文介绍了mpi4py返回排名差异的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我想在两个不同版本的python中从python脚本(为了进行测试，以交互方式进行测试，但不是从ipython来)进行并行处理，并且已经从mpi4py开始.这两个版本分别是(分别用于2个和8个内核):

I want to launch parallel processes from a python script (and, for testing, interactively, but not from ipython), across two different versions of python, and have started out with mpi4py. The two versions are (for 2 and 8 cores respectively):

Python 2.7.2 | EPD 7.2-2(64位)| (默认值，2011年9月7日，16:31:15)达尔文[GCC 4.0.1(Apple Inc.内部版本5493)]

Python 2.7.2 |EPD 7.2-2 (64-bit)| (default, Sep 7 2011, 16:31:15)[GCC 4.0.1 (Apple Inc. build 5493)] on darwin

和

Python 2.6.5(r265:79063，2010年4月16日，13:57:41)linux2上的[GCC 4.4.3]

Python 2.6.5 (r265:79063, Apr 16 2010, 13:57:41)[GCC 4.4.3] on linux2

在第一个(用于学习绳索)上，我得到交互:

On the first one (to learn the ropes), interactively I get:

from mpi4py import MPI
import sys
size = MPI.COMM_WORLD.Get_size()
print size

rank = MPI.COMM_WORLD.Get_rank()
print rank

这不是我想要的(并且执行mpirun/mpiexec python似乎挂起/不执行任何操作).但是，如果我这样做:

which is not what I want (and doing mpirun/mpiexec python just seems to hang/do nothing). But if I do:

mpiexec -n 5 python helloworld.py

上

#!/usr/bin/env python

from mpi4py import MPI
import sys

size = MPI.COMM_WORLD.Get_size()
rank = MPI.COMM_WORLD.Get_rank()
name = MPI.Get_processor_name()

sys.stdout.write(
    "Hello, World! I am process %d of %d on %s.\n"
    % (rank, size, name))

我知道

你好，世界！我正在本地主机上处理5个进程中的0个.

Hello, World! I am process 0 of 5 on localhost.

你好，世界！我是本地主机上的进程1，共5个.

Hello, World! I am process 1 of 5 on localhost.

你好，世界！我是本地主机上的进程2，共5个.

Hello, World! I am process 2 of 5 on localhost.

你好，世界！我是本地主机上的进程3，共5.

Hello, World! I am process 3 of 5 on localhost.

你好，世界！我正在本地主机上处理5之4.

Hello, World! I am process 4 of 5 on localhost.

以交互方式启动python时，如何获得size> 0?