1.添加超時(shí)時(shí)間：

fromthreading import Thread, Lock
importtime 
mutex1= Lock()  # 創(chuàng)建一個(gè)互斥鎖
mutex2= Lock()  # 創(chuàng)建一個(gè)互斥鎖

def fun1():
    while True:
        mutex1.acquire()
        print("線程1 鎖住了mutex1")
        time.sleep(0.1)
 
        result =mutex2.acquire(timeout=1)  # timeout指明acquire等的最長(zhǎng)超時(shí)時(shí)間
        # result = mutex2.acquire(False)  # 非阻塞
        if result:
            # 表示對(duì)mutex2成功上鎖
            print("線程1 鎖住了mutex2")
            print("線程1 hello")
            mutex1.release()
            mutex2.release()
            break
        else:
            # 表示對(duì)mutex2上鎖失敗
           mutex1.release()  # 將mutex1釋放，保證別人能夠執(zhí)行
            time.sleep(0.1)

def fun2():
    mutex2.acquire()
    print("線程2 鎖住了mutex2")
    time.sleep(0.1)
    mutex1.acquire()
    print("線程2 鎖住了mutex1")
    print("線程2 hi") 
    mutex1.release()
    mutex2.release()

2.附錄-銀行家算法（ 不要求，理解就可以）

背景知識(shí)

一個(gè)銀行家如何將一定數(shù)目的資金安全地借給若干個(gè)客戶，使這些客戶既能借到錢完成要干的事，同時(shí)銀行家又能收回全部資金而不至于破產(chǎn)，這就是銀行家問(wèn)題。這個(gè)問(wèn)題同操作系統(tǒng)中資源分配問(wèn)題十分相似：銀行家就像一個(gè)操作系統(tǒng)，客戶就像運(yùn)行的進(jìn)程，銀行家的資金就是系統(tǒng)的資源。

問(wèn)題的描述

一個(gè)銀行家擁有一定數(shù)量的資金，有若干個(gè)客戶要貸款。每個(gè)客戶須在一開始就聲明他所需貸款的總額。若該客戶貸款總額不超過(guò)銀行家的資金總數(shù)，銀行家可以接收客戶的要求?？蛻糍J款是以每次一個(gè)資金單位（如1萬(wàn)RMB等）的方式進(jìn)行的，客戶在借滿所需的全部單位款額之前可能會(huì)等待，但銀行家須保證這種等待是有限的，可完成的。

例如：有三個(gè)客戶C1，C2，C3，向銀行家借款，該銀行家的資金總額為10個(gè)資金單位，其中C1客戶要借9各資金單位，C2客戶要借3個(gè)資金單位，C3客戶要借8個(gè)資金單位，總計(jì)20個(gè)資金單位。某一時(shí)刻的狀態(tài)如圖所示。

對(duì)于a圖的狀態(tài)，按照安全序列的要求，我們選的第一個(gè)客戶應(yīng)滿足該客戶所需的貸款小于等于銀行家當(dāng)前所剩余的錢款，可以看出只有C2客戶能被滿足：C2客戶需1個(gè)資金單位，小銀行家手中的2個(gè)資金單位，于是銀行家把1個(gè)資金單位借給C2客戶，使之完成工作并歸還所借的3個(gè)資金單位的錢，進(jìn)入b圖。同理，銀行家把4個(gè)資金單位借給C3客戶，使其完成工作，在c圖中，只剩一個(gè)客戶C1，它需7個(gè)資金單位，這時(shí)銀行家有8個(gè)資金單位，所以C1也能順利借到錢并完成工作。最后（見(jiàn)圖d）銀行家收回全部10個(gè)資金單位，保證不賠本。那麼客戶序列{C1，C2，C3}就是個(gè)安全序列，按照這個(gè)序列貸款，銀行家才是安全的。否則的話，若在圖b狀態(tài)時(shí)，銀行家把手中的4個(gè)資金單位借給了C1，則出現(xiàn)不安全狀態(tài)：這時(shí)C1，C3均不能完成工作，而銀行家手中又沒(méi)有錢了，系統(tǒng)陷入僵持局面，銀行家也不能收回投資。

綜上所述，銀行家算法是從當(dāng)前狀態(tài)出發(fā)，逐個(gè)按安全序列檢查各客戶誰(shuí)能完成其工作，然后假定其完成工作且歸還全部貸款，再進(jìn)而檢查下一個(gè)能完成工作的客戶，......。如果所有客戶都能完成工作，則找到一個(gè)安全序列，銀行家才是安全的。

補(bǔ)充：python基礎(chǔ)-死鎖、遞歸鎖

死鎖

所謂死鎖：是指兩個(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)程

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(2)
        mutexA.acquire()
        print('\033[44m%s 拿到A鎖\033[0m' %self.name)
        mutexA.release()
        mutexB.release()
if __name__ == '__main__':
    for i in range(5):
        t=MyThread()
        t.start()

輸出如下：

Thread-1 拿到A鎖

Thread-1 拿到B鎖

Thread-1 拿到B鎖

Thread-2 拿到A鎖

分析如上代碼是如何產(chǎn)生死鎖的：

啟動(dòng)5個(gè)線程，執(zhí)行run方法，假如thread1首先搶到了A鎖，此時(shí)thread1沒(méi)有釋放A鎖，緊接著執(zhí)行代碼mutexB.acquire()，搶到了B鎖，在搶B鎖時(shí)候，沒(méi)有其他線程與thread1爭(zhēng)搶，因?yàn)锳鎖沒(méi)有釋放，其他線程只能等待，然后A鎖就執(zhí)行完func1代碼，然后繼續(xù)執(zhí)行func2代碼，與之同時(shí)，在func2中，執(zhí)行代碼 mutexB.acquire()，搶到了B鎖，然后進(jìn)入睡眠狀態(tài)，在thread1執(zhí)行完func1函數(shù)，釋放AB鎖時(shí)候，其他剩余的線程也開始搶A鎖，執(zhí)行func1代碼，如果thread2搶到了A鎖，接下來(lái)thread2要搶B鎖，ok，在這個(gè)時(shí)間段，thread1已經(jīng)執(zhí)行func2搶到了B鎖，然后在sleep(2),持有B鎖沒(méi)有釋放，為什么沒(méi)有釋放，因?yàn)闆](méi)有其他的線程與之爭(zhēng)搶，他只能睡著，然后thread1握著B鎖，thread2要搶B鎖，ok，這樣就形成了死鎖

遞歸鎖

我們分析了死鎖，那么python里面是如何解決這樣的遞歸鎖呢？

在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ā)生死鎖：

from threading import Thread,Lock,RLock
import time
mutexA=mutexB=RLock()
class MyThread(Thread):
    def run(self):
        self.f1()
        self.f2()
    def f1(self):
        mutexA.acquire()
        print('%s 拿到A鎖' %self.name)
        mutexB.acquire()
        print('%s 拿到B鎖' %self.name)
        mutexB.release()
        mutexA.release()
    def f2(self):
        mutexB.acquire()
        print('%s 拿到B鎖' % self.name)
        time.sleep(0.1)
        mutexA.acquire()
        print('%s 拿到A鎖' % self.name)
        mutexA.release()
        mutexB.release()
if __name__ == '__main__':
    for i in range(5):
        t=MyThread()
        t.start()

輸出代碼如下：

E:\python\python_sdk\python.exe "E:/python/py_pro/3 死鎖現(xiàn)象與遞歸鎖.py"

Thread-1 拿到A鎖

Thread-1 拿到B鎖

Thread-1 拿到B鎖

Thread-1 拿到A鎖

Thread-2 拿到A鎖

Thread-2 拿到B鎖

Thread-2 拿到B鎖

Thread-2 拿到A鎖

Thread-4 拿到A鎖

Thread-4 拿到B鎖

Thread-4 拿到B鎖

Thread-4 拿到A鎖

Thread-3 拿到A鎖

Thread-3 拿到B鎖

Thread-3 拿到B鎖

Thread-3 拿到A鎖

Thread-5 拿到A鎖

Thread-5 拿到B鎖

Thread-5 拿到B鎖

Thread-5 拿到A鎖

Process finished with exit code 0

或者如下的效果：

來(lái)解釋下遞歸鎖的代碼：

由于鎖A，B是同一個(gè)遞歸鎖，thread1拿到A,B鎖，counter記錄了acquire的次數(shù)2次，然后在func1執(zhí)行完畢，就釋放遞歸鎖，在thread1釋放完遞歸鎖，執(zhí)行完func1代碼，接下來(lái)會(huì)有2種可能，1、thread1在次搶到遞歸鎖，執(zhí)行func2代碼 2、其他的線程搶到遞歸鎖，去執(zhí)行func1的任務(wù)代碼

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。

最新評(píng)論