当我们使用multiprocessing时,可能会发现进程之间不共享全局变量。
问题示例:
让我们来看一个问题的例子,有两个输入列表,两个进程从中读取并将其附加到最终列表,然后将合并的列表打印输出。
import multiprocessing
final_list = []
input_list_one = ['a', 'b', 'c', 'd']
input_list_two = ['e', 'f', 'g']
def worker(data):
for item in data:
final_list.append(item)
process1 = multiprocessing.Process(target=worker, args=[final_list_one])
process2 = multiprocessing.Process(target=worker, args=[final_list_two])
process1.start()
process2.start()
process1.join()
process2.join()
print(final_list)
运行代码时:
$ python3 mp_list_issue.py
[]
如大家所看到的,输出列表为空。
解决方案:
我们需要使用multiprocessing.Manager.List。
摘自Python文档:</