Python：使用多維multiprocessing.manager.list（）

Question

這可能不是它的預期用途，但我想知道如何使用多維的manager.list（）。我可以創建就好了，這樣的事情：

from multiprocessing import manager 

test = manager.list(manager.list()) 

然而當過我嘗試訪問它會返回元素的值，而不是它的代理對象測試列表的第一個元素

test[0] # returns [] and not the proxy, since I think python is running __getitem__. 

是無論如何，我可以解決這個問題，並以這種方式使用manager.list（）？

Answer 1

的multiprocessing documentation對此有一張紙條：

注意

的修改可變值或字典和列表代理項目將 不通過管理器來傳播，因爲代理沒有方式 知道它的值或項目何時被修改。要修改這樣一個項目， 你可以重新修改的對象到容器代理：

# create a list proxy and append a mutable object (a dictionary) 
lproxy = manager.list() 
lproxy.append({}) 
# now mutate the dictionary 
d = lproxy[0] 
d['a'] = 1 
d['b'] = 2 
# at this point, the changes to d are not yet synced, but by 
# reassigning the dictionary, the proxy is notified of the change 
lproxy[0] = d 

因此，使用多維列表中的唯一方法是實際重新分配您對第二任何改變列表回到頂層列表的尺寸，所以不是：

test[0][0] = 1 

你這樣做：

tmp = test[0] 
tmp[0] = 1 
test[0] = tmp 

不是最愉快的做事方式，但你可以寫一些幫手功能，讓它更容易一些。

編輯：

看來，你會得到一個簡單的列表後面的原因，當你追加一個ListProxy另一個ListProxy是因爲酸洗代理是如何工作的。 BaseProxy.__reduce__創建了一個RebuildProxy對象，該對象實際上用於取消打開Proxy。 RebuildProxy看起來是這樣的：

def RebuildProxy(func, token, serializer, kwds): 
    ''' 
    Function used for unpickling proxy objects. 

    If possible the shared object is returned, or otherwise a proxy for it. 
    ''' 
    server = getattr(process.current_process(), '_manager_server', None) 

    if server and server.address == token.address: 
     return server.id_to_obj[token.id][0] 
    else: 
     incref = (
      kwds.pop('incref', True) and 
      not getattr(process.current_process(), '_inheriting', False) 
      ) 
     return func(token, serializer, incref=incref, **kwds) 

由於文檔字符串說，如果在unpickle被管理服務器的內部存在的，創建實際的共享對象，而不是Proxy它。這可能是一個bug，並且there is actually one filed已經對此行爲了。