python - 循环中的多处理， "Pool not running"错误

Question

我试图在循环中运行一些计算，每个计算都会创建、使用和关闭一个池。但计算只运行一次，然后抛出错误:“池未运行”。当然旧的没有运行，但新的不应该创建吗？

下面是一个简化的例子，类似于我的代码。更奇怪的是，在我的实际代码计算中，在崩溃之前运行了 7 次，所以我真的很困惑是什么问题。任何建议表示赞赏!

from pathos.multiprocessing import ProcessingPool as Pool

def add_two(number):  
    return (number + 2)

def parallel_function(numbers):
    pool = Pool(10)
    result = pool.imap(add_two, numbers)
    pool.close()
    pool.join()    
    return(result)

sets=[
    [1, 2, 3],
    [2, 3, 4],
    [3, 4, 5]
]

for one_set in sets:
    x = parallel_function(one_set)
    for i in x:
        print(i)

Answer 1

这是一个 pathos使用单例模式实现池的限制。

这是相关的issue ticket .

我建议您使用另一个 Pool of Workers 实现。