一、進(jìn)程之間的數(shù)據(jù)共享

展望未來，基于消息傳遞的并發(fā)編程是大勢(shì)所趨

即便是使用線程，推薦做法也是將程序設(shè)計(jì)為大量獨(dú)立的線程集合，通過消息隊(duì)列交換數(shù)據(jù)。

這樣極大地減少了對(duì)使用鎖定和其他同步手段的需求，還可以擴(kuò)展到分布式系統(tǒng)中。

但進(jìn)程間應(yīng)該盡量避免通信，即便需要通信，也應(yīng)該選擇進(jìn)程安全的工具來避免加鎖帶來的問題。

以后我們會(huì)嘗試使用數(shù)據(jù)庫(kù)來解決現(xiàn)在進(jìn)程之間的數(shù)據(jù)共享問題。

1.1 Manager模塊介紹

進(jìn)程間數(shù)據(jù)是獨(dú)立的，可以借助于隊(duì)列或管道實(shí)現(xiàn)通信， 二者都是基于消息傳遞的。

雖然進(jìn)程間數(shù)據(jù)獨(dú)立，但可以通過Manager實(shí)現(xiàn)數(shù)據(jù)共享，事實(shí)上Manager的功能遠(yuǎn)不止于此。

A manager object returned by Manager() controls a server process which holds Python objects and allows other processes to manipulate them using proxies.

A manager returned by Manager() will support types list, dict, Namespace, Lock, RLock, Semaphore, BoundedSemaphore, Condition, Event, Barrier, Queue, Value and Array.

1.2 Manager例子

          
            from multiprocessing import Manager,Process,Lock
def work(d,lock):
    with lock:  # 不加鎖而操作共享的數(shù)據(jù),肯定會(huì)出現(xiàn)數(shù)據(jù)錯(cuò)亂
        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)