python - 并行 : Run for loop in Python

Question

我想让我的coed并行运行，如下所示，

for j in range(nj):
    for i in range(ni):
        # assign matrix coefficient

这是一个非常大的矩阵，导致执行时间非常短，我如何并行运行这种代码？

提前致谢!

Answer 1

您可能正在寻找 multiprocessing 模块。

import multiprocessing
import random
import time

def f(x,y):
    print multiprocessing.current_process()
    time.sleep(random.random())
    return x*y

p = multiprocessing.Pool(10)
res= []
for i in xrange(1,10):
  for j in xrange(1,10):
    res.append(p.apply_async(f, [i,j]))

for r in res:
  print r.get()