如果沒有控制多個(gè)線程對同一資源的訪問，對數(shù)據(jù)造成破壞，使得線程運(yùn)行的結(jié)果不可預(yù)期。這種現(xiàn)象稱為“線程不安全”。

?

線程同步解決問題:

系統(tǒng)調(diào)用t1，然后獲取到num的值為0，此時(shí)上一把鎖，即不允許其他現(xiàn)在操作num

對num的值進(jìn)行+1

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

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

?

from threading import Thread, Lock

?

num =0? # 資源競爭問題

mutex= Lock()? # 創(chuàng)建一個(gè)互斥鎖

def fun1():

??? global num

??? for i in range(1000000):

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

??????? # acquire 首先判斷鎖的當(dāng)前狀態(tài)，如果鎖處于上鎖狀態(tài)，則默認(rèn)處于阻塞等待，

??????? # 等待直到鎖變成未上鎖狀態(tài)的時(shí)候，才能繼續(xù)向下運(yùn)行

??????? # 如果一旦發(fā)現(xiàn)鎖處于未上鎖狀態(tài)，則將鎖設(shè)置為上鎖

??????? num += 1

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

?

def fun2():

??? global num

??? for i in range(1000000):

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

??????? num += 1

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

?

?

t1 =Thread(target=fun1)? # 創(chuàng)建一個(gè)線程對象

t2 =Thread(target=fun2)? # 創(chuàng)建一個(gè)線程對象

?

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

t2.start()

?

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

t2.join()

?

print(num)

?

總結(jié)

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

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