我试图在循环中运行一些计算,每个计算都会创建、使用和关闭一个池。但是计算只运行一次,然后就抛出一个错误:“池未运行”。当然旧的没有运行,但是新的不应该被创建吗?
下面是一个简化的示例,类似于我的代码。更奇怪的是,在我的实际代码中,计算在崩溃之前运行了7次,所以我真的很困惑问题出在哪里。任何建议都将不胜感激!
下面是一个简化的示例,类似于我的代码。更奇怪的是,在我的实际代码中,计算在崩溃之前运行了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)