所以我試圖在一個字典上使用多處理管理器，這是我最初的嘗試：from multiprocessing import Process, Managerdef task(stat): test['z'] += 1 test['y']['Y0'] += 5if __name__ == '__main__': test = Manager().dict({'x': {'X0': 10, 'X1': 20}, 'y': {'Y0': 0, 'Y1': 0}, 'z': 0}) p = Process(target=task, args=(test,)) p.start() p.join() print(test)當然，當我運行它時，輸出不是我所期望的，z正確更新而y不變！這是輸出：{'x': {'X0': 10, 'X1': 20}, 'y': {'Y0': 0, 'Y1': 0}, 'z': 1}然后我用谷歌搜索，在這里找到了一個解釋，顯然嵌套的字典也必須是Manager().dict()s 而不是普通的 python 字典（可能從 Python 3.6 開始）。所以我做了以下事情：from multiprocessing import Process, Managerdef task(stat): test['z'] += 1 test['y']['Y0'] += 5if __name__ == '__main__': test = Manager().dict({'x': Manager().dict({'X0': 10, 'X1': 20}), 'y': Manager().dict({'Y0': 0, 'Y1': 0}), 'z': 0}) p = Process(target=task, args=(test,)) p.start() p.join() print(test) print(test['y'])但是，我得到了這個無法解釋的錯誤，而不是它正常工作，為了清楚起見，它分為三個部分。第一部分對應于，test['y']['Y0'] += 5而第二部分是簡單的print(test)，最后是輸出print(test['y'])我不確定為什么會這樣。內部 dicts 顯然是被創建的（如輸出的第二部分所示）。但是由于某種原因，它們根本無法讀取或寫入！為什么會這樣？額外：如果我通過 python 控制臺（而不是腳本）運行相同的 python 代碼，錯誤會FileNotFoundError從ConnectionRefusedError. 但是具有相同的確切回溯！
1 回答
FFIVE
TA貢獻1797條經驗 獲得超6個贊
隨著你每次都開始一個新的經理流程，所以你真的在嵌套經理（就像標題所說的那樣），這不是它應該的方式Manager()。Manager().dict()相反，您需要做的是實例化一個Manager，然后在該 manager 實例上創建字典：
from multiprocessing import Process, Manager
from multiprocessing.managers import DictProxy
def task(test): # use parameter `test`, else you rely on forking
test['z'] += 1
test['y']['Y0'] += 5
if __name__ == '__main__':
with Manager() as m:
test = m.dict({'x': m.dict({'X0': 10, 'X1': 20}),
'y': m.dict({'Y0': 0, 'Y1': 0}),
'z': 0})
p = Process(target=task, args=(test,))
p.start()
p.join()
print(test)
print(test['y'])
# convert to normal dict before closing manager for persistence
# in parent or for printing dict behind proxies
d = {k: dict(v) if isinstance(v, DictProxy) else v
for k, v in test.items()}
print(d) # Manager already closed here
示例輸出：
{'x': <DictProxy object, typeid 'dict' at 0x7f98cdaaa588>, 'y': <DictProxy object, typeid 'dict' at 0x7f98cda99c50>, 'z': 1}
{'Y0': 5, 'Y1': 0}
{'x': {'X0': 10, 'X1': 20}, 'y': {'Y0': 5, 'Y1': 0}, 'z': 1}
Process finished with exit code 0
Manager.Lock如果您計劃從多個進程修改管理器對象，您還需要使用它。
添加回答
舉報
0/150
提交
取消