如何处理multiprocessing.Pool()初始化错误?
简而言之,我使用:
pool = multiprocessing.Pool(os.cpu_count(), initializer=init)
def init():
# stop everything if that fails with exception
# init..
相关问题如何处理multiprocessing.Pool中的初始化错误?
但它没有展示如何干净地退出主进程。
是否可能从池中获取每个Process
实例并在它们中的每一个上运行一个函数?
请注意,这不同于pool.map
,因为我不知道我的函数将在哪个进程中运行。
Pool
设计支持的内容,例如maxtasksperchild
会导致池循环,因此进程不应保持稳定。每个进程是否可以单独失败?即为什么不只是将某些成功函数映射到几个进程上。 - Sam Masonmap
在每个进程上运行? - user3599803