一、共享数据

进程间通信应该尽量避免使用本节所讲的共享数据方式

 

from multiprocessing import Manager,Process,Lock
def work(dic,mutex):
    with mutex:
        dic['count']-=1
if __name__ == '__main__':
    mutex=Lock()
    m=Manager()
    share_dic=m.dict({'count':50})
    p_l=[]
    for i in range(50):
        p=Process(target=work,args=(share_dic,mutex))
        p_l.append(p)
        p.start()
    for p in p_l:
        p.join()
    print(share_dic)
进程之间操作共享的数据

相关文章: