python并發(fā)編程多進程互斥鎖原理解析

更新時間：2019年08月20日 14:50:48 作者：minger_lcm

這篇文章主要介紹了python并發(fā)編程多進程互斥鎖原理解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

運行多進程每個子進程的內(nèi)存空間是互相隔離的進程之間數(shù)據(jù)不能共享的

互斥鎖

但是進程之間都是運行在一個操作系統(tǒng)上，進程之間數(shù)據(jù)不共享,但是共享同一套文件系統(tǒng),所以訪問同一個文件,或同一個打印終端,

是可以的，而共享帶來的是競爭，競爭帶來的結(jié)果就是錯亂

#并發(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)生間后上一把鎖，其他人都要等著，等到這個完成任務(wù)后釋放鎖，其他人才有可能有一個搶到......

所以互斥鎖的原理，就是把并發(fā)改成串行，降低了效率，但保證了數(shù)據(jù)安全，不錯亂

加了互斥鎖就沒有并發(fā)效果了加上鎖只有一個可以運行互斥鎖會把并發(fā)變成串行效率變低了

解決：

導(dǎo)入模塊 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
'''

犧牲了效率，保證數(shù)據(jù)不錯亂

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: