小编Zac*_*0ne的帖子

我正在尝试并行运行在循环中有返回值的函数。但它似乎停留在results = pool.map(algorithm_file.foo, population)for 循环的第二次迭代中

    raise ValueError("Pool not running")
ValueError: Pool not running

示例代码：

from multiprocessing.dummy import Pool
import algorithm_file

population = [1, 3, 4]
pool = Pool(len(population))

total = list()

for _ in range(10):
    results = pool.map(algorithm_file.foo, population)
    pool.close()
    pool.join()
    total.append(sum(results))

print(total)

里面的内容algorithm_file.py

from random import randint

def foo(x):
    return x * randint(0,5)

我尝试放入pool = Pool(len(population))for 循环，但程序毫无例外地崩溃了。

我发现一些解决方案使用全局列表（）。但无论如何，有没有办法维护具有返回值的函数呢？

Python 3.7.3