编写了一个进程池,有5个子进程并行运行,共运行40个批次,现在遇到的问题,如果一个子进程结束,其他的子进程也会结束,如何解决?
python代码如下:
pool = multiprocessing.Pool(processes=5) # 创建4个进程
for i in range(len(Alist_paths)):
msg = Alist_paths[i]
pool.apply_async(super, (i,msg,))
pool.close()
pool.join()
time.sleep(2)
print('wait 2 second to terminate the multiprocess')