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

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

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

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

互斥鎖

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

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

#并發(fā)運(yùn)行,效率高,但競爭同一打印終端,帶來了打印錯(cuò)亂
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=("子進(jìn)程%s" % i,))
    p.start()
'''
子進(jìn)程2 1
子進(jìn)程0 1
子進(jìn)程1 1
子進(jìn)程2 2
子進(jìn)程1 2
子進(jìn)程0 2
子進(jìn)程2 3
子進(jìn)程1 3
子進(jìn)程0 3
'''

如何控制，就是加鎖處理。而互斥鎖的意思就是互相排斥，如果把多個(gè)進(jìn)程比喻為多個(gè)人，

互斥鎖的工作原理就是多個(gè)人都要去爭搶同一個(gè)資源：衛(wèi)生間，一個(gè)人搶到衛(wèi)生間后上一把鎖，其他人都要等著，等到這個(gè)完成任務(wù)后釋放鎖，其他人才有可能有一個(gè)搶到......

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

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

解決：

導(dǎo)入模塊 Lock

現(xiàn)在程序啟動(dòng) 所有進(jìn)程首先會(huì)去搶鎖只有搶到鎖的才能運(yùn)行

等這個(gè)進(jìn)程運(yùn)行完了解鎖后再到其他進(jì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__':
  # 建一個(gè)對(duì)象實(shí)例
  mutex = Lock()
  for i in range(3):
    # 把鎖傳給子進(jìn)程 讓所有子進(jìn)程用同一把鎖
    p = Process(target=task, args=("子進(jìn)程%s" % i, mutex))
    p.start()
'''
現(xiàn)在程序啟動(dòng) 所有進(jìn)程首先會(huì)去搶鎖 只有搶到鎖的才能運(yùn)行
等這個(gè)進(jìn)程運(yùn)行完了解鎖后 再到其他進(jìn)程繼續(xù)搶鎖
'''
'''
子進(jìn)程0 1
子進(jìn)程0 2
子進(jìn)程0 3
子進(jìn)程1 1
子進(jìn)程1 2
子進(jìn)程1 3
子進(jìn)程2 1
子進(jìn)程2 2
子進(jìn)程2 3
'''

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

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

您可能感興趣的文章: