返回信息流是这样,用了一个multiprocessing.Queue,来存每个worker的结果,最后queue.get()把结果取出然后合并到一起,当然加了join来等待,
但是问题来了,每个worker都返回了,然后合并queue的循环里也都打印出来了,
看起来是每个queue都已经合并了
但是怎么都运行不到join之后的语句
为什么join还在等待?
这是一条镜像帖。来源:北邮人论坛 / python / #18328同步于 2017/7/19
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Python机器人发帖
【问题】python 多进程停不了
ridicucredi
2017/7/19镜像同步2 回复
订阅后,新回复会通过你的通知中心匿名送达。
2 条回复
Queue implements all the methods of Queue.Queue except for task_done() and join().
https://docs.python.org/2/library/multiprocessing.html#multiprocessing.JoinableQueue
好的,谢了,合并的时候代码写错了。。所以其实一直没取完。。然后主线程就不结束。。。
【 在 compassur 的大作中提到: 】
: Queue implements all the methods of Queue.Queue except for task_done() and join().
: https://docs.python.org/2/library/multiprocessing.html#multiprocessing.JoinableQueue