在並行進程之間共享信號量對象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()調用實際上將返回一個代理隊列，而不是隊列本身，並且管理器進程將處理後臺中所有必需的同步。