您好,登錄后才能下訂單哦!
一、進程之間的數據共享
展望未來,基于消息傳遞的并發編程是大勢所趨
即便是使用線程,推薦做法也是將程序設計為大量獨立的線程集合,通過消息隊列交換數據。
這樣極大地減少了對使用鎖定和其他同步手段的需求,還可以擴展到分布式系統中。
但進程間應該盡量避免通信,即便需要通信,也應該選擇進程安全的工具來避免加鎖帶來的問題。
以后我們會嘗試使用數據庫來解決現在進程之間的數據共享問題。
1.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.
1.2 Manager例子
manager這里可以共享列表,字典等很多數據類型
from multiprocessing import Manager,Process,Lock def work(d,lock): lock.acquire() d['count'] -= 1 lock.release() 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)
{'count':0}
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。