如何在python中停止一个多进程



当尝试在for循环中运行多进程时,所有进程都在执行,但程序没有终止并继续运行。

如何在列表中的所有元素被处理后停止程序?

def multiprocess_for_loop(*args, list_to_iter_over, function):
# the element in iterable is the first argument in the function
output = Queue()
processes = [Process(target=function, args=(elem,) + args) for elem in list_to_iter_over]
logging.info(f"start multiprocess for-loop on list: {list_to_iter_over}")
for p in processes:
p.start()
results = []
for p in processes:
results.append(output.get())
for p in processes:
p.join()
logging.info("finished multiprocessing for-loop")
return results

每个进程都在Queue上写?如果一个进程不写它,你的代码就会卡在里面。

最新更新