Python并发编程:多线程-死锁现象与递归锁
生活随笔
收集整理的這篇文章主要介紹了
Python并发编程:多线程-死锁现象与递归锁
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
一 死鎖現(xiàn)象
所謂死鎖:是指兩個(gè)或兩個(gè)以上的進(jìn)程或線程在執(zhí)行過程中,因爭奪資源而造成的一種互相等待的現(xiàn)象,若無外力作用,它們都將無法推進(jìn)下去。此時(shí)稱系統(tǒng)處于死鎖狀態(tài)或系統(tǒng)產(chǎn)生了死鎖,這些永遠(yuǎn)在互相等待的進(jìn)程稱為死鎖進(jìn)程,如下就是死鎖
from threading import Thread, Lock import time mutexA = Lock() mutexB = Lock()class MyThread(Thread):def run(self):self.func1()self.func2()def func1(self):mutexA.acquire()print('\033[41m%s 拿到A鎖\033[0m' % self.name)mutexB.acquire()print('\033[42m%s 拿到B鎖\033[0m' % self.name)mutexB.release()mutexA.release()def func2(self):mutexB.acquire()print('\033[43m%s 拿到B鎖\033[0m' % self.name)time.sleep(3)mutexA.acquire()print('\033[44m%s 拿到A鎖\033[0m' % self.name)mutexA.release()mutexB.release()if __name__ == '__main__':for i in range(10):t = MyThread()t.start()執(zhí)行效果
Thread-1 拿到A鎖 Thread-1 拿到B鎖 Thread-1 拿到B鎖 Thread-2 拿到A鎖 # 出現(xiàn)死鎖,整個(gè)程序阻塞
二 遞歸鎖
解決方法,遞歸鎖,在Python中為了支持在同一線程中多次請求同一資源,Python提供了可重入鎖RLock
這個(gè)RLock內(nèi)部維護(hù)著一個(gè)Lock和一個(gè)counter變量,counter記錄了acquire的次數(shù),從而使得資源可以被多次require。直到一個(gè)線程所有的acquire都被release,其它的線程才能獲得資源。上面的例子如果使用RLock代替Lock,則不會(huì)發(fā)生死鎖,二者的區(qū)別是:遞歸鎖可以連續(xù)acquire多次,而互斥鎖只能acquire一次
# 遞歸鎖 from threading import Thread, RLock import timemutexA = mutexB = RLock() # 一個(gè)線程拿到鎖,counter加1,該線程內(nèi)又碰到加鎖的情況,則counter繼續(xù)加1,這期間所有其他線程都只能等待,等待該線程釋放所有鎖,即counter遞減到0為止class MyThread(Thread):def run(self):self.func1()self.func2()def func1(self):mutexA.acquire()print('\033[41m%s 拿到A鎖\033[0m' % self.name)mutexB.acquire()print('%s 拿到B鎖' % self.name)mutexB.release()mutexA.release()def func2(self):mutexB.acquire()print('\033[43m%s 拿到B鎖\033[0m' % self.name)mutexA.acquire()print('%s 拿到A鎖' % self.name)mutexA.release()mutexB.release()if __name__ == '__main__':for i in range(10):t = MyThread()t.start()
?
轉(zhuǎn)載于:https://www.cnblogs.com/mike-liu/p/9293812.html
總結(jié)
以上是生活随笔為你收集整理的Python并发编程:多线程-死锁现象与递归锁的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: iview 使用笔记
- 下一篇: 操作系统识别-python、nmap