python多線程死鎖現(xiàn)象及解決方法

第python多線程死鎖現(xiàn)象及解決方法目錄本節(jié)重點(diǎn)一死鎖現(xiàn)象二遞歸鎖

本節(jié)重點(diǎn)

了解死鎖現(xiàn)象與解決方法

本節(jié)時(shí)長(zhǎng)需控制在15分鐘內(nèi)

一死鎖現(xiàn)象

所謂死鎖：是指兩個(gè)或兩個(gè)以上的進(jìn)程或線程在執(zhí)行過(guò)程中，因爭(zhēng)奪資源而造成的一種互相等待的現(xiàn)象，若無(wú)外力作用，它們都將無(wú)法推進(jìn)下去。

此時(shí)稱系統(tǒng)處于死鎖狀態(tài)或系統(tǒng)產(chǎn)生了死鎖，這些永遠(yuǎn)在互相等待的進(jìn)程稱為死鎖進(jìn)程，如下就是死鎖

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()

執(zhí)行效果

Thread-1拿到A鎖

Thread-1拿到B鎖

Thread-1拿到B鎖

Thread-2拿到A鎖#出現(xiàn)死鎖，整個(gè)程序阻塞住

二遞歸鎖

解決方法，遞歸鎖，在Python中為了支持在同一線程中多次請(qǐng)求同一資源，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一次

fromthreadingimportThread,RLock

importtime

mutexA=mutexB=RLock()#一個(gè)線程拿到鎖，counter加1,該線程內(nèi)又碰到加鎖的情況，則counter繼續(xù)加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):