最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

python多線程互斥鎖與死鎖

 更新時間:2022年02月10日 12:07:17   作者:侯小啾 ?  
這篇文章主要介紹了python多線程互斥鎖與死鎖,多線程間的資源競爭下文我們就以task1(),task2()兩個函數為例,分別將對全局變量num加一重復一千萬次循環(huán),具有一定得參考價值,需要的小伙伴可以參考一下

一、多線程間的資源競爭

以下列task1(),task2()兩個函數為例,分別將對全局變量num加一重復一千萬次循環(huán)(數據大一些,太小的話執(zhí)行太快,達不到驗證的效果)。

import threading
import time

num = 0


def task1(nums):
? ? global num
? ? for i in range(nums):
? ? ? ? num += 1

? ? print("task1---num=%d" % num)


def task2(nums):
? ? global num
? ? for i in range(nums):
? ? ? ? num += 1
? ? print("task2---num=%d" % num)


if __name__ == '__main__':
? ? nums = 10000000
? ? t1 = threading.Thread(target=task1, args=(nums,))
? ? t2 = threading.Thread(target=task2, args=(nums,))

? ? t1.start()
? ? t2.start()
? ? # 因為主線程不會等子線程執(zhí)行完就會執(zhí)行,所以這里延遲五秒,確保最后執(zhí)行。
? ? time.sleep(5)
? ? print("main----num=%d" % num)

程序運行結果:

如圖,輸出結果比較混亂,既沒有一千萬,最終結果也不是二千萬。因為多線程運行時出現了資源競爭,即可以理解為,每個函數運行的時間都不確定,且互相影響,
如從初始值0開始,假設t1的線程先執(zhí)行,執(zhí)行到+1后,此時的num=1還未存儲,然后即被叫停,t2開始執(zhí)行,去獲取num,獲取到的num等于初始值0,然后其執(zhí)行了+1并存儲,存儲后num=1,然后t2停止t1繼續(xù),再次存儲num=1。即加了兩次1,但是num還是只等于1。
因為t1和t2誰來運行的分配是完全隨機的,所以最后加了兩千萬次1后值是小于2000萬的。

解決此類問題,可以使用到互斥鎖 。

二、互斥鎖

  • 某個線程要更改共享數據時,先將其鎖定,此時資源的狀態(tài)為"鎖定",其他線程不能改變,只到該線程釋放資源,將資源的狀態(tài)變成"非鎖定",其他的線程才能再次鎖定該資源。
  • 互斥鎖保證了每次只有一個線程進行寫入操作,從而保證了多線程情況下數據的正確性。

1.互斥鎖示例

創(chuàng)建一把鎖:

mutex = threading.Lock()
mutex.acquire() # 上鎖
xxxx鎖定的內容xxxxx
mutex.release() # 解鎖

將互斥鎖加入到上邊的代碼中如下,則問題得到了解決。

import threading
import time

num = 0


def task1(nums):
? ? global num
? ? mutex.acquire()
? ? for i in range(nums):
? ? ? ? num += 1
? ? mutex.release()
? ? print("task1---num=%d" % num)


def task2(nums):
? ? global num
? ? mutex.acquire()
? ? for i in range(nums):
? ? ? ? num += 1
? ? mutex.release()
? ? print("task2---num=%d" % num)


if __name__ == '__main__':
? ? nums = 10000000
? ? mutex = threading.Lock()
? ? t1 = threading.Thread(target=task1, args=(nums,))
? ? t2 = threading.Thread(target=task2, args=(nums,))

? ? t1.start()
? ? t2.start()
? ? # 因為主線程不會等子線程執(zhí)行完就會執(zhí)行,所以這里延遲五秒,確保最后執(zhí)行。
? ? time.sleep(5)
? ? print("main----num=%d" % num)

程序運行結果:

2.可重入鎖與不可重入鎖

threading.Lock()上的是不可重入鎖,即一次只能加一把鎖,不能加多把。

threading.Lock()

如果需要同時加多把所,則需加入不可重入鎖

創(chuàng)建一把可重入鎖:

mutex = threading.RLock()
mutex.acquire() # 上鎖
mutex.acquire() # 再上鎖
xxxx鎖定的內容xxxxx
mutex.release() # 解鎖
mutex.release() # 再解鎖

其中上鎖和解鎖的次數必須保持一致。

三、死鎖

在線程間共享多個資源的時候,如果兩個線程分別占有一部分資源并且同時等待對方的資源,就會程序堵塞,造成死鎖。

  • 死鎖一般用不到。
  • 程序設計要盡量避免。

到此這篇關于python多線程互斥鎖與死鎖的文章就介紹到這了,更多相關python多線程互斥鎖與死鎖內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

最新評論

广饶县| 台山市| 都昌县| 曲靖市| 揭阳市| 于田县| 隆林| 营口市| 阿克苏市| 巴南区| 天水市| 饶河县| 桐乡市| 芜湖县| 岱山县| 鄂托克前旗| 青川县| 渝中区| 彭阳县| 宜宾县| 义马市| 利辛县| 香河县| 仁布县| 莱芜市| 柳河县| 贵南县| 钦州市| 泰州市| 博乐市| 德江县| 穆棱市| 方山县| 合川市| 简阳市| 公主岭市| 广南县| 密山市| 万载县| 文安县| 武强县|