类似于多处理的mpi池
mpipool的Python项目详细描述
关于
mpipool提供了一个类似的Pool类multiprocessing.Pool
从标准库。
mpipool使用MPIPool实现
schwimmbad库
并规避其某些限制：
- 一系列的
mpipool.Pool.map调用不会崩溃， - 如果工作进程引发异常，则MPI 任务被正确关闭，以便整个程序停止并执行 不是吊死。
示例用法
from mpipool import Pool
def add(a, b):
return a + b
p = Pool()
sums = p.map(add, [(ai, bi) for ai in range(10) for bi in range(10)])
assert len(sums) == 100
assert sums[0] == 0
assert sums[-1] == 18
sums = p.map(add, [(ai, bi) for ai in range(10) for bi in range(10)])
assert len(sums) == 100
assert sums[0] == 0
assert sums[-1] == 18
程序必须在命令行上运行，如：
$ mpirun -n 4 python example.py
目前mpipool.Pool只实现一个map方法。
与MPIPool实现相反
schwimmbadfrom mpipool import Pool之后的语句只执行
按排序为0的任务。
学分
mpipool使用MPIPool实现
schwimmbad库。
欢迎加入QQ群-->： 979659372
