在并行进程之间共享信号量对象python

Question

当我使用并行python传递任何信号量对象或同步对象（如事件，管道，队列等等）到子进程时遇到问题 当我通过并行python时出现跟随错误一个队列到子进程。 “通过继承”％类型（个体经营）.__ name__ RuntimeError：队列对象只能进程之间通过继承共享

当我用一个多进程库

import pp 
import time 
from multiprocessing import Event, Queue, Manager, Pool 

e = Queue() 

def startt() : 
    e.put(1) 
    return 1 


ppservers =() 
# Creates jobserver with automatically detected number of workers   
jobServer = pp.Server(ppservers=ppservers,proto=2) 
#submit the work to the job pool or job server 
job = jobServer.submit(startt,(e,),(),("time",), globals = globals()) 
res = job() 
print e.get() 
print res 

Answer 1

没有问题是seeen你”重新当您提交作业有这个问题，因为你传递的队列对象：

job = jobServer.submit(startt,(e,),(),("time",), globals = globals()) 
#       ^here 

有两点需要注意：

1. 队列已经是全球性的。你不需要将它作为参数传递。

2. 您可以如果您使用过的队列作为参数multiprocessing.Manager：

manager = multiprocessing.Manager() 
shared_queue = manager.Queue() # this shared queue can be passed as an argument 

到manager.Queue()调用实际上将返回一个代理队列，而不是队列本身，并且管理器进程将处理后台中所有必需的同步。