如果沒有控制多個線程對同一資源的訪問，對數據造成破壞，使得線程運行的結果不可預期。這種現象稱為“線程不安全”。

?

線程同步解決問題:

系統調用t1，然后獲取到num的值為0，此時上一把鎖，即不允許其他現在操作num

對num的值進行+1

解鎖，此時num的值為1，其他的線程就可以使用num了，而且是num的值不是0而是1

同理其他線程在對num進行修改時，都要先上鎖，處理完后再解鎖，在上鎖的整個過程中不允許其他線程訪問，就保證了數據的正確性

?

from threading import Thread, Lock

?

num =0? # 資源競爭問題

mutex= Lock()? # 創建一個互斥鎖

def fun1():

??? global num

??? for i in range(1000000):

?????? ?mutex.acquire()

??????? # acquire 首先判斷鎖的當前狀態，如果鎖處于上鎖狀態，則默認處于阻塞等待，

??????? # 等待直到鎖變成未上鎖狀態的時候，才能繼續向下運行

??????? # 如果一旦發現鎖處于未上鎖狀態，則將鎖設置為上鎖

??????? num += 1

????? ??mutex.release()? # 釋放鎖，表示將鎖設置為打開狀態

?

def fun2():

??? global num

??? for i in range(1000000):

???? ???mutex.acquire()

??????? num += 1

?????? ?mutex.release()? # 釋放鎖，表示將鎖設置為打開狀態

?

?

t1 =Thread(target=fun1)? # 創建一個線程對象

t2 =Thread(target=fun2)? # 創建一個線程對象

?

t1.start()? # 開啟線程的執行

t2.start()

?

t1.join()? # 回收線程資源

t2.join()

?

print(num)

?

總結

以上是生活随笔為你收集整理的python中的互斥锁的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。