并发编程-进程-08进程间数据共享

一丶进程间数据分享介绍(推荐队列)

展望将来,基于消息传递的并发编程是大势所趋python

即使是使用线程,推荐作法也是将程序设计为大量独立的线程集合编程

经过消息队列交换数据。这样极大地减小了对使用锁定和其余同步手段的需求,并发

还能够扩展到分布式系统中app

进程间通讯应该尽可能避免使用本节所讲的共享数据的方式分布式

进程间数据是独立的,能够借助于队列或管道实现通讯,两者都是基于消息传递的

虽然进程间数据独立,但能够经过Manager实现数据共享,事实上Manager的功能远不止于此

二丶数据共享实现

from multiprocessing import Manager,Process,Lock
def work(d,lock):
    with lock:  # 不加锁而操做共享的数据,确定会出现数据错乱
        d['count']-=1

if __name__ == '__main__':
    lock=Lock()
    with Manager() as m:
        dic=m.dict({'count':100})
        p_l=[]
        for i in range(100):
            p=Process(target=work,args=(dic,lock))
            p_l.append(p)
            p.start()
        for p in p_l:
            p.join()
        print(dic)
相关文章
相关标签/搜索