我尝试使用Python 2.7的多进程包创建队列列表。每个子进程拥有一个独立的队列,并且有两个任务:从自己的队列中获取元素并将元素放入其他子进程的队列中。因此,每个子进程都必须知道它所属的队列,这就是我使用队列列表的原因。
我的代码如下:
但是,我收到了以下错误信息:
我的代码如下:
mgr = multiprocessing.Manager()
sharedQueueList = mgr.list()
for i in xrange(num_processes):
sharedQueueList .append(mgr.Queue())
但是,我收到了以下错误信息:
**raise convert_to_error(kind, result)**
RemoteError:
---------------------------------------------------------------------------
Unserializable message: ('#RETURN', < Queue.Queue instance at 0x02AD3170 >)
---------------------------------------------------------------------------