如何在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
When trying to run multiprocessing on a for loop all the process are being executed but the program is not terminated and keep running.
How can i stop the program after all elements in the list got processed?
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
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
每个过程都在队列上写？
如果一个过程不写在其中，则您的代码会粘在其中。
Every process write on Queue?
If a process don't write in it, your code keep stuck in that for.