我在他们的网站本身尝试了一个简单的python多处理示例,但它没有提供任何输入。它显示为自己运行,我无法在jupyter笔记本中停止它。
from multiprocessing import Pool
def f(x):
return x*x
if __name__ == '__main__':
p = Pool(5)
print(p.map(f, [1, 2, 3]))
对于其他多处理示例也是如此。它不会给出任何错误或超时或任何东西。它就像是无限循环或死锁。
我不知道如何但是当我导入如下所示时它起作用。
from multiprocessing.pool import ThreadPool as Pool
问题在于导入多处理的池。