1、互斥鎖

為解決資源搶奪問題，使用mutex = Threading.Lock()創(chuàng)建鎖，使用mutex.acquire()鎖定，使用mutex.release()釋放鎖。
代碼一：

import threading import time# 定義一個全局變量 g_num = 0def test1(num):global g_num# 上鎖，如果之前沒有被上鎖，那么此時 上鎖成功# 如果上鎖之前 已經(jīng)被上鎖了，那么此時會堵塞在這里，直到 這個鎖被解開位置mutex.acquire()for i in range(num):g_num += 1# 解鎖mutex.release()print("-----in test1 g_num=%d----" % g_num)def test2(num):global g_nummutex.acquire()for i in range(num):g_num += 1mutex.release()print("-----in test2 g_num=%d=----" % g_num)# 創(chuàng)建一個互斥鎖，默認是沒有上鎖的 mutex = threading.Lock()def main():t1 = threading.Thread(target=test1, args=(1000000,))t2 = threading.Thread(target=test2, args=(1000000,))t1.start()t2.start()# 等待上面的2個線程執(zhí)行完畢....time.sleep(2)print("-----in main Thread g_num = %d---" % g_num)if __name__ == "__main__":main()

運行結果：

-----in test1 g_num=1000000---- -----in test2 g_num=2000000=---- -----in main Thread g_num = 2000000---

代碼二：（注意，更改了上鎖的位置）

import threading import time# 定義一個全局變量 g_num = 0def test1(num):global g_numfor i in range(num):mutex.acquire() # 上鎖g_num += 1mutex.release() # 解鎖print("-----in test1 g_num=%d----" % g_num)def test2(num):global g_numfor i in range(num):mutex.acquire() # 上鎖g_num += 1mutex.release() # 解鎖print("-----in test2 g_num=%d=----" % g_num)# 創(chuàng)建一個互斥鎖，默認是沒有上鎖的 mutex = threading.Lock()def main():t1 = threading.Thread(target=test1, args=(1000000,))t2 = threading.Thread(target=test2, args=(1000000,))t1.start()t2.start()# 等待上面的2個線程執(zhí)行完畢....time.sleep(2)print("-----in main Thread g_num = %d---" % g_num)if __name__ == "__main__":main()

運行結果：

-----in test1 g_num=1920966---- -----in test2 g_num=2000000=---- -----in main Thread g_num = 2000000---

鎖的位置不一樣，導致兩個線程在運行中進度不一樣（線程一在執(zhí)行到1920966時，就已經(jīng)釋放鎖，并輸出次數(shù)，并由線程二接力），但是兩個程序總的線程數(shù)仍然一樣。

2.死鎖

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結

以上是生活随笔為你收集整理的Python多线程--互斥锁、死锁的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。