您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

在队列为空之前调用join时,Python 3多处理队列死锁

在队列为空之前调用join时,Python 3多处理队列死锁

允许数据在进程之间传输的多处理队列实现依赖于标准OS管道。

OS管道的长度不是无限长,因此在put()操作期间,可能会在OS中阻止将数据排队的进程,直到其他一些进程用来get()从队列中检索数据为止。

对于少量数据(例如您的示例中的数据),主流程可以将join()所有产生的子流程然后获取数据。这通常效果很好,但无法扩展,也不清楚何时断开。

但是它肯定会破坏大量数据。子流程将在put()等待主流程通过删除队列中的某些数据时get()被阻止,但是主流程在join()等待子流程完成时被阻塞。这将导致死锁。

这是用户遇到此确切问题的示例。我在答案中张贴了一些代码,帮助他解决了问题。

python 2022/1/1 18:45:55 有324人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶