无法更新多处理的 manager.dict() 中的嵌套字典值

我正在尝试更新多处理模块的 manager.dict() 的嵌套字典中的键，但无法这样做。它不会更新值，也不会引发任何错误。

Code:

import time
import random
from multiprocessing import Pool, Manager

def spammer_task(d, token, repeat):
    success = 0
    fail = 0
    while success+fail<repeat:
        time.sleep(random.random()*2.0)
        if (random.random()*100)>98.0:
            fail+=1
        else:
            success+=1
        d[token] = {
            'status': 'ongoing',
            'fail': fail,
            'success': success,
            'repeat': repeat
        }
    print d[token]['status']
    d[token]['status'] = 'complete'
    return

p = Pool()
m = Manager()
d = m.dict()

p.apply_async(spammer_task (d, 'abc', 5))
print d

Output:

ongoing

{'abc': {'状态': '正在进行', '失败': 0, '重复': 5, '成功': 5}}

我的期望是，一旦 while 循环结束，它应该使 d['abc']['status'] = 完成。但在最终打印时，它仅将其状态打印为“正在进行”。

不知道为什么，但 Manager DictProxy 对象似乎无法处理嵌套部分的变异。这段代码有效：

import time
import random
from multiprocessing import Pool, Manager

def spammer_task(d, token, repeat):
    success = 0
    fail = 0
    while success+fail<repeat:
        time.sleep(random.random()*2.0)
        if (random.random()*100)>98.0:
            fail+=1
        else:
            success+=1
        d[token] = {
            'status': 'ongoing',
            'fail': fail,
            'success': success,
            'repeat': repeat,
        }
    print d[token]['status']
    foo = d[token]
    foo['status'] = 'complete'
    d[token] = foo
    return

p = Pool()
m = Manager()
d = m.dict()

p.apply_async(spammer_task(d, 'abc', 5))
print d