在多線程中，當(dāng)多個(gè)線程同時(shí)處理一個(gè)共享資源(如文件)時(shí)(向文件中讀寫數(shù)據(jù))，為了避免并發(fā)修改錯(cuò)誤(多個(gè)線程訪問同一資源導(dǎo)致數(shù)據(jù)不一致)，使用了某種鎖定機(jī)制，當(dāng)一個(gè)線程訪問一個(gè)資源時(shí)，它會(huì)鎖定該資源，直到它釋放該鎖定，其他線程都不能訪問同一資源。

站在用戶的角度思考問題，與客戶深入溝通，找到高陵網(wǎng)站設(shè)計(jì)與高陵網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類型包括：做網(wǎng)站、網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、空間域名、雅安服務(wù)器托管、企業(yè)郵箱。業(yè)務(wù)覆蓋高陵地區(qū)。

---

鎖對象:Python 多線程

在 Python 的threading模塊中，為了高效多線程，使用了一個(gè)原語鎖。這個(gè)鎖幫助我們同步兩個(gè)或多個(gè)線程。鎖類可能提供了 Python 中最簡單的同步原語。

原始鎖可以有兩種狀態(tài):鎖定或解鎖，并且最初是在我們初始化 lock 對象時(shí)在解鎖狀態(tài)下創(chuàng)建的。它有兩種基本方法，acquire()和release()。

以下是創(chuàng)建鎖對象的基本語法:

import threading

threading.Lock()

鎖對象使用兩種方法，它們是:

acquire(blocking=True, timeout=-1)方法

此方法用于獲取鎖。當(dāng)它在沒有參數(shù)的情況下被調(diào)用時(shí)，它會(huì)一直阻塞，直到鎖被解鎖。

該方法可以采用 2 個(gè)可選參數(shù)，它們是:

1. 阻塞標(biāo)志，如果該鎖已經(jīng)被某個(gè)其他線程獲得，則該標(biāo)志如果作為False發(fā)送，將不會(huì)阻塞該線程，并將作為結(jié)果返回False。如果您將該阻塞標(biāo)志的值提供為True，那么如果其他線程持有鎖，調(diào)用線程將被阻塞，一旦鎖被釋放，那么您的線程將獲得鎖并返回True。
2. timeout 參數(shù)用于提供一個(gè)正浮點(diǎn)值，該值指定如果其他線程正在持有鎖，調(diào)用線程將被阻塞的秒數(shù)。默認(rèn)值為 -1 表示如果線程不能立即獲得鎖，它將被無限期阻塞。

release()方法

它用于釋放獲取的鎖。如果鎖被鎖定，這個(gè)方法會(huì)將其重置為解鎖狀態(tài)，然后返回。此外，該方法可以從任何線程調(diào)用。

當(dāng)調(diào)用此方法時(shí)，已經(jīng)等待獲取鎖的線程中的一個(gè)被允許持有鎖。

此外，如果在未鎖定的鎖上調(diào)用它，它會(huì)拋出RuntimeError。

---

是時(shí)候舉個(gè)例子了！

下面我們有一個(gè)簡單的 python 程序，其中我們有一個(gè)類SharedCounter，它將作為線程之間的共享資源。

我們有一個(gè)task方法，我們稱之為increment()方法。由于多個(gè)線程將訪問同一個(gè)計(jì)數(shù)器并增加其值，因此存在并發(fā)修改的可能性，這可能導(dǎo)致counter的值不一致。

請始終從上面的代碼中獲取:

1. 當(dāng)一個(gè)線程使用acquire()方法獲取鎖，然后訪問一個(gè)資源時(shí)，如果在訪問資源的過程中出現(xiàn)了一些錯(cuò)誤，會(huì)怎么樣？在這種情況下，沒有其他線程能夠訪問該資源，因此我們必須訪問try塊內(nèi)的資源。在finally區(qū)塊內(nèi)部，我們可以調(diào)用release()方法來重新鎖定。
2. 嘗試注釋第 13 行和第 19 行的代碼，并嘗試多次運(yùn)行代碼，有時(shí)您會(huì)看到代碼會(huì)給出正確的輸出，但有時(shí)您會(huì)看到不正確的counter值。

---

---

文章名稱：Python中的鎖對象——線程同步
當(dāng)前網(wǎng)址：http://uogjgqi.cn/article/dhshgic.html