1、互斥鎖

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

import threading
import time# 定義一個全局變量
g_num = 0def test1(num):global g_num# 上鎖，如果之前沒有被上鎖，那么此時 上鎖成功# 如果上鎖之前 已經被上鎖了，那么此時會堵塞在這里，直到 這個鎖被解開位置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)# 創建一個互斥鎖，默認是沒有上鎖的
mutex = threading.Lock()def main():t1 = threading.Thread(target=test1, args=(1000000,))t2 = threading.Thread(target=test2, args=(1000000,))t1.start()t2.start()# 等待上面的2個線程執行完畢....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)# 創建一個互斥鎖，默認是沒有上鎖的
mutex = threading.Lock()def main():t1 = threading.Thread(target=test1, args=(1000000,))t2 = threading.Thread(target=test2, args=(1000000,))t1.start()t2.start()# 等待上面的2個線程執行完畢....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---

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

2.死鎖