1. 程式人生 > >程序(五):程序之間的資料共享

程序(五):程序之間的資料共享

展望未來,基於訊息傳遞的併發程式設計是大勢所趨

即便是使用執行緒,推薦做法也是將程式設計為大量獨立的執行緒集合,通過訊息佇列交換資料。

這樣極大地減少了對使用鎖定和其他同步手段的需求,還可以擴充套件到分散式系統中。

但程序間應該儘量避免通訊,即便需要通訊,也應該選擇程序安全的工具來避免加鎖帶來的問題。

以後我們會嘗試使用資料庫來解決現在程序之間的資料共享問題。

Manager模組介紹

程序間資料是獨立的,可以藉助於佇列或管道實現通訊,二者都是基於訊息傳遞的
雖然程序間資料獨立,但可以通過Manager實現資料共享,事實上Manager的功能遠不止於此

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.

#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)