Python 2.6通过Queue/Pipe/etc发送连接对象 [英] Python 2.6 send connection object over Queue / Pipe / etc

问题描述

给出此错误(Python第4892版)，该错误会引起以下错误:

Given this bug (Python Issue 4892) that gives rise to the following error:

>>> import multiprocessing
>>> multiprocessing.allow_connection_pickling()
>>> q = multiprocessing.Queue()
>>> p = multiprocessing.Pipe()
>>> q.put(p)
>>> q.get()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File     "/.../python2.6/multiprocessing/queues.py", line 91, in get
    res = self._recv()
TypeError: Required argument 'handle' (pos 1) not found

有人知道在队列上传递Connection对象的解决方法吗?

Does anyone know of a workaround to pass a Connection object on a Queue?

谢谢.

推荐答案

(我相信是)一种更好的方法，经过一些测试(我遇到了同样的问题.想将管道穿过管道).发现这篇文章:

(What I believe is) A better method, after some playing around (I was having the same problem. Wanted to pass a pipe through a pipe.) before discovering this post:

>>> from multiprocessing import Pipe, reduction
>>> i, o = Pipe()
>>> reduced = reduction.reduce_connection(i)
>>> newi = reduced[0](*reduced[1])
>>> newi.send("hi")
>>> o.recv()
'hi'

我不完全确定为什么要这样构建(有人需要深入了解多处理的减少部分到底要做什么)，但它确实有效，并且不需要导入泡菜.除此之外，它的工作与上面的工作非常接近，但更为简单.我还将其放入python bug报告中，以便其他人知道解决方法.

I'm not entirely sure why this is built this way (someone would need insight into what the heck the reduction part of multiprocessing is about for that) but it does definitely work, and requires no pickle import. Other than that, it's pretty close to the above in what it does, but simpler. I also threw this into the python bug report so others know of the workaround.

这篇关于Python 2.6通过Queue/Pipe/etc发送连接对象的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！