一旦Python的一个工作线程满足某个条件，就终止它的多处理程序

Question

我正在使用它的多处理模块编写一个Python程序。该程序调用许多辅助函数，每个函数都产生一个随机数。一旦其中一个工人产生大于0.7的数字，我就需要终止程序。

下面是我的程序，其中“如何执行此操作”部分尚未填写。知道吗？谢谢。

import time
import numpy as np
import multiprocessing as mp
import time
import sys

def f(i):
    np.random.seed(int(time.time()+i))

    time.sleep(3)
    res=np.random.rand()
    print "From i = ",i, "       res = ",res
    if res>0.7:
        print "find it"
        # terminate  ???? Question: How to do this???


if __name__=='__main__':
    num_workers=mp.cpu_count()
    pool=mp.Pool(num_workers)
    for i in range(num_workers):
        p=mp.Process(target=f,args=(i,))
        p.start()

Answer 1

有一种更干净的python方法来完成您想做的事情，它是通过使用multiprocessing.Pool提供的回调函数来实现的。

您可以检查this question以查看实现示例。