允许数据在进程之间传输的多处理队列实现依赖于标准OS管道。
OS管道的长度不是无限长,因此在put()
操作期间,可能会在OS中阻止将数据排队的进程,直到其他一些进程用来get()
从队列中检索数据为止。
对于少量数据(例如您的示例中的数据),主流程可以将join()
所有产生的子流程然后获取数据。这通常效果很好,但无法扩展,也不清楚何时断开。
但是它肯定会破坏大量数据。子流程将在put()
等待主流程通过删除队列中的某些数据时get()
被阻止,但是主流程在join()
等待子流程完成时被阻塞。这将导致死锁。