python多線程中互斥鎖Threading.Lock的簡(jiǎn)單應(yīng)用

這篇文章主要講解了“python多線程中互斥鎖Threading.Lock的簡(jiǎn)單應(yīng)用”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“python多線程中互斥鎖Threading.Lock的簡(jiǎn)單應(yīng)用”吧！

一、線程共享進(jìn)程資源

每個(gè)線程互相獨(dú)立，相互之間沒(méi)有任何關(guān)系，但是在同一個(gè)進(jìn)程中的資源，線程是共享的，如果不進(jìn)行資源的合理分配，對(duì)數(shù)據(jù)造成破壞，使得線程運(yùn)行的結(jié)果不可預(yù)期。這種現(xiàn)象稱(chēng)為“線程不安全”。

實(shí)例如下：

#-*- coding: utf-8 -*-
import threading
import time
 
def test_xc():
  f = open("test.txt","a")
  f.write("test_dxc"+'\n')
  time.sleep(1)
  f.close()
 
if __name__ == '__main__':
  for i in xrange(5):
    t = threading.Thread(target=test_xc)
    t.start()

結(jié)果展示：

二、互斥鎖同步

線程同步能夠保證多個(gè)線程安全訪問(wèn)競(jìng)爭(zhēng)資源，最簡(jiǎn)單的同步機(jī)制是引入互斥鎖?；コ怄i為資源引入一個(gè)狀態(tài)：鎖定/非鎖定。某個(gè)線程要更改共享數(shù)據(jù)時(shí)，先將其鎖定，此時(shí)資源的狀態(tài)為“鎖定”，其他線程不能更改；直到該線程釋放資源，將資源的狀態(tài)變成“非鎖定”，其他的線程才能再次鎖定該資源。互斥鎖保證了每次只有一個(gè)線程進(jìn)行寫(xiě)入操作，從而保證了多線程情況下數(shù)據(jù)的正確性。

threading模塊中定義了Lock類(lèi)，可以方便的處理鎖定：

#創(chuàng)建鎖
mutex = threading.Lock()
#鎖定
mutex.acquire([timeout])#timeout是超時(shí)時(shí)間
#釋放
mutex.release()

其中，鎖定方法acquire可以有一個(gè)超時(shí)時(shí)間的可選參數(shù)timeout。如果設(shè)定了timeout，則在超時(shí)后通過(guò)返回值可以判斷是否得到了鎖，從而可以進(jìn)行一些其他的處理。

三、使用線程鎖

<pre name="code" class="python">#-*- coding: utf-8 -*-
import threading
import time
 
def test_xc():
  f = open("test.txt","a")
  f.write("test_dxc"+'\n')
  time.sleep(1)
  mutex.acquire()#取得鎖
  f.close()
  mutex.release()#釋放鎖
 
if __name__ == '__main__':
  mutex = threading.Lock()#創(chuàng)建鎖
  for i in xrange(5):
    t = threading.Thread(target=test_xc)
    t.start()

運(yùn)行結(jié)果

感謝各位的閱讀，以上就是“python多線程中互斥鎖Threading.Lock的簡(jiǎn)單應(yīng)用”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)python多線程中互斥鎖Threading.Lock的簡(jiǎn)單應(yīng)用這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！