python多線程死鎖現象及解決方法

第python多線程死鎖現象及解決方法目錄本節重點一死鎖現象二遞歸鎖

本節重點

了解死鎖現象與解決方法

本節時長需控制在15分鐘內

一死鎖現象

所謂死鎖：是指兩個或兩個以上的進程或線程在執行過程中，因爭奪資源而造成的一種互相等待的現象，若無外力作用，它們都將無法推進下去。

此時稱系統處于死鎖狀態或系統產生了死鎖，這些永遠在互相等待的進程稱為死鎖進程，如下就是死鎖

fromthreadingimportThread,Lock

importtime

mutexA=Lock()

mutexB=Lock()

classMyThread(Thread):

defrun(self):

self.func1()

self.func2()

deffunc1(self):

mutexA.acquire()

print('\033[41m%s拿到A鎖\033[0m'%)

mutexB.acquire()

print('\033[42m%s拿到B鎖\033[0m'%)

mutexB.release()

mutexA.release()

deffunc2(self):

mutexB.acquire()

print('\033[43m%s拿到B鎖\033[0m'%)

time.sleep(2)

mutexA.acquire()

print('\033[44m%s拿到A鎖\033[0m'%)

mutexA.release()

mutexB.release()

if__name__=='__main__':

foriinrange(10):

t=MyThread()

t.start()

執行效果

Thread-1拿到A鎖

Thread-1拿到B鎖

Thread-1拿到B鎖

Thread-2拿到A鎖#出現死鎖，整個程序阻塞住

二遞歸鎖

解決方法，遞歸鎖，在Python中為了支持在同一線程中多次請求同一資源，python提供了可重入鎖RLock。

這個RLock內部維護著一個Lock和一個counter變量，counter記錄了acquire的次數，從而使得資源可以被多次require。直到一個線程所有的acquire都被release，其他的線程才能獲得資源。

上面的例子如果使用RLock代替Lock，則不會發生死鎖，二者的區別是：遞歸鎖可以連續acquire多次，而互斥鎖只能acquire一次

fromthreadingimportThread,RLock

importtime

mutexA=mutexB=RLock()#一個線程拿到鎖，counter加1,該線程內又碰到加鎖的情況，則counter繼續加1，這期間所有其他線程都只能等待，等待該線程釋放所有鎖，即counter遞減到0為止

classMyThread(Thread):

defrun(self):

self.func1()

self.func2()

deffunc1(self):

mutexA.acquire()

print('\033[41m%s拿到A鎖\033[0m'%)

mutexB.acquire()

print('\033[42m%s拿到B鎖\033[0m'%)

mutexB.release()

mutexA.release()

deffunc2(self):

mutexB.acquire()

print('\033[43m%s拿到B鎖\033[0m'%)

time.sleep(2)

mutexA.acquire()

print('\033[44m%s拿到A鎖\033[0m'%)

mutexA.release()

mutexB.release()

if__name__=='__main__':

foriinrange(10):