python进程池,当target函数中遇见某些情况要立即退出本次任务,跳到加载下一次任务怎么实现?

def run(idx):  
    invl = random.randint(5, 20)  
    if invl > 10:  
        sys_exit(0)  
    else:  
        sleep(invl)  
  
pool = Pool(3)  
for i in range(1, 10):  
    rslt = pool.apply_async(run, args=(i,))  

pool.close()  
pool.join()

当interval > 10 后 进程退出,小于10则等待秒数。
可是这样实现,最后三个进程不能被join,而且每次都是fork新的进程,也没有复用前面被exit的进程号。

阅读 1.6k
1 个回答

run 函数返回即可,无需退出进程。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题