您好,登錄后才能下訂單哦!
這篇文章主要介紹“python并發(fā)編程中多進程與互斥鎖的原理解析”,在日常操作中,相信很多人在python并發(fā)編程中多進程與互斥鎖的原理解析問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”python并發(fā)編程中多進程與互斥鎖的原理解析”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!
運行多進程 每個子進程的內存空間是互相隔離的 進程之間數據不能共享的
互斥鎖
但是進程之間都是運行在一個操作系統(tǒng)上,進程之間數據不共享,但是共享同一套文件系統(tǒng),所以訪問同一個文件,或同一個打印終端,
是可以的,而共享帶來的是競爭,競爭帶來的結果就是錯亂
#并發(fā)運行,效率高,但競爭同一打印終端,帶來了打印錯亂 from multiprocessing import Process import time def task(name): print("%s 1" % name) time.sleep(1) print("%s 2" % name) time.sleep(1) print("%s 3" % name) if __name__ == '__main__': for i in range(3): p = Process(target=task, args=("子進程%s" % i,)) p.start() ''' 子進程2 1 子進程0 1 子進程1 1 子進程2 2 子進程1 2 子進程0 2 子進程2 3 子進程1 3 子進程0 3 '''
如何控制,就是加鎖處理。而互斥鎖的意思就是互相排斥,如果把多個進程比喻為多個人,
互斥鎖的工作原理就是多個人都要去爭搶同一個資源:衛(wèi)生間,一個人搶到衛(wèi)生間后上一把鎖,其他人都要等著,等到這個完成任務后釋放鎖,其他人才有可能有一個搶到......
所以互斥鎖的原理,就是把并發(fā)改成串行,降低了效率,但保證了數據安全,不錯亂
加了互斥鎖就沒有并發(fā)效果了 加上鎖只有一個可以運行 互斥鎖會把并發(fā)變成串行 效率變低了
解決:
導入模塊 Lock
現(xiàn)在程序啟動 所有進程首先會去搶鎖 只有搶到鎖的才能運行
等這個進程運行完了解鎖后 再到其他進程繼續(xù)搶鎖
from multiprocessing import Process, Lock import time def task(name, mutex): # 加鎖 mutex.acquire() print("%s 1" % name) time.sleep(1) print("%s 2" % name) time.sleep(1) print("%s 3" % name) # 把鎖拆了 mutex.release() if __name__ == '__main__': # 建一個對象實例 mutex = Lock() for i in range(3): # 把鎖傳給子進程 讓所有子進程用同一把鎖 p = Process(target=task, args=("子進程%s" % i, mutex)) p.start() ''' 現(xiàn)在程序啟動 所有進程首先會去搶鎖 只有搶到鎖的才能運行 等這個進程運行完了解鎖后 再到其他進程繼續(xù)搶鎖 ''' ''' 子進程0 1 子進程0 2 子進程0 3 子進程1 1 子進程1 2 子進程1 3 子進程2 1 子進程2 2 子進程2 3 '''
犧牲了效率,保證數據不錯亂
到此,關于“python并發(fā)編程中多進程與互斥鎖的原理解析”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續(xù)學習更多相關知識,請繼續(xù)關注億速云網站,小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。