我有一本字典my_dict
包含列表和一个可迭代keys
了很多,我想上运行的功能键:并行化修改字典
for key in keys:
if key in my_dict:
my_dict[key].append(my_fun(key, params))
else:
my_dict[key] = [my_fun(key, params)]
my_fun
是缓慢的。我该如何平行化这个循环?
难道仅仅是:
import multiprocessing
def _process_key(key):
if key in my_dict:
my_dict[key].append(my_fun(key, params))
else:
my_dict[key] = [my_fun(key, params)]
if __name__ == '__main__':
with Pool(5) as p:
p.map(_process_key, keys)
不,字典需要在父级更新。 – tdelaney
我有点困惑......你用相同的键多次调用'my_fun' ...我认为这是故意的? – tdelaney