并行读取 Python Shelve 对象

Question

我想并行化以下从搁置的 python 对象读取的 for 循环

result = []
for k in my_keys:
val = my_shelved_db[k]
result.append(val)

其中 ：my_shelved_db = shelve.open('my_file.db')

有人可以举个例子如何做到这一点

吗

Answer 1

import multiprocessing
from multiprocessing import Manager
manager = Manager()
result = manager.list()
def func(k):
val = my_shelved_db[k]
result.append(val)
# my_keys = range(10)
for  k in my_keys:
process = multiprocessing.Process(target=func,args=(k,))
process.start()

print(result)