前言

在使用多線(xiàn)程的應(yīng)用下，如何保證線(xiàn)程安全，以及線(xiàn)程之間的同步，或者訪(fǎng)問(wèn)共享變量等問(wèn)題是十分棘手的問(wèn)題，也是使用多線(xiàn)程下面臨的問(wèn)題，如果處理不好，會(huì)帶來(lái)較嚴(yán)重的后果，使用python多線(xiàn)程中提供Lock 、Rlock 、Semaphore 、Event 、Condition 用來(lái)保證線(xiàn)程之間的同步，后者保證訪(fǎng)問(wèn)共享變量的互斥問(wèn)題。

• Lock & RLock：互斥鎖，用來(lái)保證多線(xiàn)程訪(fǎng)問(wèn)共享變量的問(wèn)題
• Semaphore對(duì)象：Lock互斥鎖的加強(qiáng)版，可以被多個(gè)線(xiàn)程同時(shí)擁有，而Lock只能被某一個(gè)線(xiàn)程同時(shí)擁有。
• Event對(duì)象：它是線(xiàn)程間通信的方式，相當(dāng)于信號(hào)，一個(gè)線(xiàn)程可以給另外一個(gè)線(xiàn)程發(fā)送信號(hào)后讓其執(zhí)行操作。
• Condition對(duì)象：其可以在某些事件觸發(fā)或者達(dá)到特定的條件后才處理數(shù)據(jù)

1、Lock(互斥鎖)

請(qǐng)求鎖定 — 進(jìn)入鎖定池等待 — — 獲取鎖 — 已鎖定— — 釋放鎖

Lock（指令鎖）是可用的最低級(jí)的同步指令。Lock處于鎖定狀態(tài)時(shí)，不被特定的線(xiàn)程擁有。Lock包含兩種狀態(tài)——鎖定和非鎖定，以及兩個(gè)基本的方法。

可以認(rèn)為L(zhǎng)ock有一個(gè)鎖定池，當(dāng)線(xiàn)程請(qǐng)求鎖定時(shí)，將線(xiàn)程至于池中，直到獲得鎖定后出池。池中的線(xiàn)程處于狀態(tài)圖中的同步阻塞狀態(tài)。

構(gòu)造方法：mylock = Threading.Lock( )

實(shí)例方法：

• acquire([timeout]): 使線(xiàn)程進(jìn)入同步阻塞狀態(tài)，嘗試獲得鎖定。
• release(): 釋放鎖。使用前線(xiàn)程必須已獲得鎖定，否則將拋出異常。

實(shí)例一（未使用鎖）：

import threading
import time
num = 0
def show(arg):
    global num
    time.sleep(1)
    num +=1
    print('bb :{}'.format(num))
for i in range(5):
    t = threading.Thread(target=show, args=(i,))  # 注意傳入?yún)?shù)后一定要有【，】逗號(hào)
    t.start()
print('main thread stop')

main thread stop
bb :1
bb :2
bb :3bb :4
bb :5

實(shí)例二（使用鎖）

import threading
import time
num = 0
lock = threading.RLock()
# 調(diào)用acquire([timeout])時(shí)，線(xiàn)程將一直阻塞，
# 直到獲得鎖定或者直到timeout秒后（timeout參數(shù)可選）。
# 返回是否獲得鎖。
def Func():
    lock.acquire()
    global num
    num += 1
    time.sleep(1)
    print(num)
    lock.release()
for i in range(10):
    t = threading.Thread(target=Func)
    t.start()

1
2
3
4
5
6
7
8
9
10
#可以看出，全局變量在在每次被調(diào)用時(shí)都要獲得鎖，才能操作，因此保證了共享數(shù)據(jù)的安全性

對(duì)于Lock對(duì)象而言，如果一個(gè)線(xiàn)程連續(xù)兩次release，使得線(xiàn)程死鎖。所以L(fǎng)ock不常用，一般采用Rlock進(jìn)行線(xiàn)程鎖的設(shè)定。

import threading
import time
class MyThread(threading.Thread):
    def run(self):
        global num 
        time.sleep(1)
        if lock.acquire(1):  
            num = num+1
            msg = self.name+' set num to '+str(num)
            print(msg)
            lock.acquire()
            lock.release()
            lock.release()
num = 0
lock = threading.Lock()
def test():
    for i in range(5):
        t = MyThread()
        t.start()
if __name__ == '__main__':
    test()
Thread-12 set num to 1

2、RLock(可重入鎖)

RLock（可重入鎖）是一個(gè)可以被同一個(gè)線(xiàn)程請(qǐng)求多次的同步指令。RLock使用了“擁有的線(xiàn)程”和“遞歸等級(jí)”的概念，處于鎖定狀態(tài)時(shí)，RLock被某個(gè)線(xiàn)程擁有。擁有RLock的線(xiàn)程可以再次調(diào)用acquire()，釋放鎖時(shí)需要調(diào)用release()相同次數(shù)?？梢哉J(rèn)為RLock包含一個(gè)鎖定池和一個(gè)初始值為0的計(jì)數(shù)器，每次成功調(diào)用 acquire()/release()，計(jì)數(shù)器將+1/-1，為0時(shí)鎖處于未鎖定狀態(tài)。

• 構(gòu)造方法：mylock = Threading.RLock()
• 實(shí)例方法：acquire([timeout])/release(): 跟Lock差不多。

實(shí)例解決死鎖，調(diào)用相同次數(shù)的acquire和release，保證成對(duì)出現(xiàn)

'''
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和PDF電子書(shū)！
'''
import threading
rLock = threading.RLock()  #RLock對(duì)象
rLock.acquire()
rLock.acquire() #在同一線(xiàn)程內(nèi)，程序不會(huì)堵塞。
rLock.release()
rLock.release()
print(rLock.acquire())

詳細(xì)實(shí)例：

import threading
mylock = threading.RLock()
num = 0
class WorkThread(threading.Thread):
    def __init__(self, name):
        threading.Thread.__init__(self)
        self.t_name = name
    def run(self):
        global num
        while True:
            mylock.acquire()
            print('\n%s locked, number: %d' % (self.t_name, num))
            if num >= 2:
                mylock.release()
                print('\n%s released, number: %d' % (self.t_name, num))
                break
            num += 1
            print('\n%s released, number: %d' % (self.t_name, num))
            mylock.release()
def test():
    thread1 = WorkThread('A-Worker')
    thread2 = WorkThread('B-Worker')
    thread1.start()
    thread2.start()
if __name__ == '__main__':
    test() 

A-Worker locked, number: 0

A-Worker released, number: 1

A-Worker locked, number: 1

A-Worker released, number: 2

A-Worker locked, number: 2

A-Worker released, number: 2

B-Worker locked, number: 2

B-Worker released, number: 2

到此這篇關(guān)于Python threading模塊中l(wèi)ock與Rlock的使用詳細(xì)講解的文章就介紹到這了,更多相關(guān)Python threading內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論