python多进程共享内存

Posted 2021-12-13 betterthanever_victor

from multiprocessing import Process,Manager,Lock
import os
import time


def run_proc(dict,slip,lock):
    tmp=dict[slip].copy()
    for k in dict[slip]:
        tmp[k]=k+tmp[k]
    print(‘Run child process{ch}... ‘.format(ch=os.getpid()))
    with lock:
        dict[slip]=tmp



if __name__ == ‘__main__‘:
    print(‘Parent process %s.‘ % os.getpid())
    dict=[{‘1‘:‘a‘,‘2‘:‘b‘,‘3‘:‘c‘},{‘4‘:‘d‘,‘5‘:‘e‘,‘6‘:‘f‘},{‘7‘:‘g‘,‘8‘:‘h‘,‘9‘:‘i‘},{‘10‘:‘j‘,‘11‘:‘k‘,‘12‘:‘l‘}]
    m = Manager()
    share_ls = m.list()
    for d in dict:
        share_ls.append(d)
    print(share_ls)
    processes = list()
    lock = Lock()#多进程锁
    for i in range(len(dict)):
        p = Process(target=run_proc, args=(share_ls,i,lock))
        p.start()
        processes.append(p)

    for p in processes:
        p.join()
    print(‘Process end.‘)
    print(share_ls)