python多处理嵌套式dictionay

我尝试在python（3.4.2）中使用多处理工具来加速我的性能。我的普通程序运行正常，但我必须在其中处理大型嵌套字典。附上了一个简化版本，它显示了我的问题。如果我直接使用TestProc它正在工作，而不是多处理。python多处理嵌套式dictionay

感谢您的帮助！

import multiprocessing 

def TestProc(liste, results): 

    for i in liste: 

     results[i] = {'power':{'square': float(i)**2, 'cubic': 
     float(i)**3},'root':{'square': float(i)**(1/2), 'cubic': float(i)**(1/3)}} 

if __name__ == "__main__": 

    multiprocessing.freeze_support() 
    results = multiprocessing.Manager().dict() 

    results = {} 
    liste = ['1','2','3','4','5'] 

    for i in liste: 

     results[i] = multiprocessing.Manager().dict() 

    print(results) 

    #TestProc(liste, results) 

    p1 = multiprocessing.Process(target=TestProc, args=(liste,results,)) 
    p1.start() 
    p1.join() 

    print(results)

来源

2017-10-16 AdrianPi

你在不使用第一个值的情况下连续两次指定'results'，并且在结果中放置了多个'multiprocessing.Manager（）。dict（）'（这应该是做什么的，不应该结果开始*空* *） – jonatan

当你这样做：

results[i] = ...

你是不是在results[i]增加值的DictProxy，您正在使用另一个品牌的新dict替换它，里面的外resultsdict。因此，唯一需要同步的是外部dict。

将第15行替换为results = multiprocessing.Manager().dict()，并删除从未做过任何事情的循环行18-20。

来源

2017-10-16 21:56:33 remram

python多处理嵌套式dictionay

回答

相关问题