您可以检查该问题,以查看解决您的问题的实现示例。
这也适用于current.futures池。
只需将map
方法替换为,apply_async
并在调用者的列表上进行迭代即可。
这样的事情。
for part in grouper(alphabet, part_size):
pool.apply_async(do_job, part, callback=self.callback)
一旦任何一个进程在python中找到匹配项,如何使所有pool.apply_async进程停止
您可以检查该问题,以查看解决您的问题的实现示例。
这也适用于current.futures池。
只需将map
方法替换为,apply_async
并在调用者的列表上进行迭代即可。
这样的事情。
for part in grouper(alphabet, part_size):
pool.apply_async(do_job, part, callback=self.callback)