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

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

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

OS管道的长度不是无限长，因此在

put()

*** 作期间，可能会在OS中阻止将数据排队的进程，直到其他一些进程用来

get()

从队列中检索数据为止。

对于少量数据（例如您的示例中的数据），主流程可以将

join()

所有产生的子流程然后获取数据。这通常效果很好，但无法扩展，也不清楚何时断开。

但是它肯定会破坏大量数据。子流程将在

put()

等待主流程通过删除队列中的某些数据时

get()

被阻止，但是主流程在

join()

等待子流程完成时被阻塞。这将导致死锁。

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