一种方法是使用管理器对象并从中创建共享列表对象:
from multiprocessing import Manager, Poolinput_list = ['A', 'B', 'C', 'D', 'E', 'F']manager = Manager()shared_list = manager.list()def do_stuff(element): global shared_list element_dict = {} element_dict['name'] = element shared_list.append(element_dict) if len(shared_list) > 3: print('list > 3')pool = Pool(processes=6)pool.map(do_stuff, input_list)pool.close()请记住,与线程不同,进程不共享内存空间。(产生时,每个进程都会获得其产生的内存足迹的副本,然后与之一起运行。)因此,它们只能通过某种形式的IPC进行通信(进程间通信)。在Python中,一种这样的方法是
multiprocessing.Manager及其公开的数据结构,例如
list或
dict。它们在代码中的用法与它们的内置等效项一样容易,但是在后台使用了某种形式的IPC(可能是套接字)。



