python – 多处理错误管道错误.Queue

发布时间：2020-12-20 12:10:16 所属栏目：Python 来源：网络整理

导读：在 python2.7中,multiprocessing.Queue在从函数内部初始化时抛出一个破坏的错误.我提供了一个重现问题的最小例子. #!/usr/bin/python# -*- coding: utf-8 -*-import multiprocessingdef main(): q = multiprocessing.Queue() for i in range(10): q.put(i)if

在 python2.7中,multiprocessing.Queue在从函数内部初始化时抛出一个破坏的错误.我提供了一个重现问题的最小例子.

#!/usr/bin/python
# -*- coding: utf-8 -*-

import multiprocessing

def main():
    q = multiprocessing.Queue()
    for i in range(10):
        q.put(i)

if __name__ == "__main__":
    main()

抛出下面破裂的管道错误

Traceback (most recent call last):
File "/usr/lib64/python2.7/multiprocessing/queues.py",line 268,in _feed
send(obj)
IOError: [Errno 32] Broken pipe

Process finished with exit code 0

我无法破译原因.我们无法从函数内部填充Queue对象,这当然很奇怪.

解决方法

这里发生的是当你调用main()时,它会创建Queue,在其中放入10个对象并结束函数,垃圾收集其所有内部变量和对象,包括Queue.
但是你得到这个错误是因为你仍在尝试发送队列中的最后一个号码.

来自文档documentation：

“When a process first puts an item on the queue a feeder thread is
started which transfers objects from a buffer into the pipe.”

由于put()是在另一个Thread中创建的,因此它不会阻止脚本的执行,并允许在完成Queue操作之前结束main()函数.

试试这个：

#!/usr/bin/python
# -*- coding: utf-8 -*-

import multiprocessing
import time
def main():
    q = multiprocessing.Queue()
    for i in range(10):
        print i
        q.put(i)
    time.sleep(0.1) # Just enough to let the Queue finish

if __name__ == "__main__":
    main()

应该有一种方法来加入队列或阻止执行,直到将对象放入队列,你应该看看文档.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!