Python線(xiàn)程threading模塊用法詳解

更新時(shí)間：2020年02月26日 11:49:44 作者：luckycyong

這篇文章主要介紹了Python線(xiàn)程threading模塊用法,結(jié)合實(shí)例形式總結(jié)分析了Python線(xiàn)程threading模塊基本功能、原理、相關(guān)函數(shù)使用方法與操作注意事項(xiàng),需要的朋友可以參考下

本文實(shí)例講述了Python線(xiàn)程threading模塊用法。分享給大家供大家參考，具體如下：

threading-更高級(jí)別的線(xiàn)程接口

源代碼：Lib/threading.py
該模塊在較低級(jí)別thread模塊之上構(gòu)建更高級(jí)別的線(xiàn)程接口。另請(qǐng)參見(jiàn)mutex和Queue模塊。

該dummy_threading模塊適用于threading因thread缺失而無(wú)法使用的情況。

注意： 從Python 2.6開(kāi)始，該模塊提供符合 PEP 8的別名和屬性，以替換camelCase受Java的線(xiàn)程API啟發(fā)的名稱(chēng)。此更新的API與multiprocessing模塊的API兼容。但是，沒(méi)有為camelCase名稱(chēng)的棄用設(shè)置計(jì)劃，它們?cè)赑ython 2.x和3.x中仍然完全受支持。

注意：從Python 2.5開(kāi)始，幾個(gè)Thread方法引發(fā)RuntimeError 而不是AssertionError錯(cuò)誤地調(diào)用。

該模塊定義了以下功能和對(duì)象：

threading.active_count（）
threading.activeCount（）
返回Thread當(dāng)前活動(dòng)的對(duì)象數(shù)。返回的計(jì)數(shù)等于返回的列表的長(zhǎng)度enumerate()。

在2.6版中更改：添加了active_count()拼寫(xiě)。

threading.Condition（）
返回新條件變量對(duì)象的工廠(chǎng)函數(shù)。條件變量允許一個(gè)或多個(gè)線(xiàn)程等待，直到另一個(gè)線(xiàn)程通知它們。

請(qǐng)參閱條件對(duì)象。

threading.current_thread（）
threading.currentThread（）
返回當(dāng)前Thread對(duì)象，對(duì)應(yīng)于調(diào)用者的控制線(xiàn)程。如果未通過(guò)threading模塊創(chuàng)建調(diào)用者的控制線(xiàn)程，則返回具有有限功能的虛擬線(xiàn)程對(duì)象。

在2.6版中更改：添加了current_thread()拼寫(xiě)。

threading.enumerate（）
返回Thread當(dāng)前活動(dòng)的所有對(duì)象的列表。該列表包括守護(hù)線(xiàn)程，由其創(chuàng)建的虛擬線(xiàn)程對(duì)象 current_thread()和主線(xiàn)程。它排除了尚未啟動(dòng)的已終止線(xiàn)程和線(xiàn)程。

threading.Event（）
返回新事件對(duì)象的工廠(chǎng)函數(shù)。事件管理一個(gè)標(biāo)志，該標(biāo)志可以使用該set()方法設(shè)置為true，并使用該方法重置為false clear()。該wait()方法將阻塞，直到該標(biāo)志為真。

請(qǐng)參閱事件對(duì)象。

類(lèi)threading.local
表示線(xiàn)程局部數(shù)據(jù)的類(lèi)。線(xiàn)程局部數(shù)據(jù)是其值是線(xiàn)程特定的數(shù)據(jù)。要管理線(xiàn)程本地?cái)?shù)據(jù)，只需創(chuàng)建一個(gè)local（或子類(lèi)）實(shí)例并在其上存儲(chǔ)屬性：

mydata = threading.local()
mydata.x = 1

對(duì)于單獨(dú)的線(xiàn)程，實(shí)例的值將不同。

有關(guān)更多詳細(xì)信息和大量示例，請(qǐng)參閱_threading_local模塊的文檔字符串。

版本2.4中的新功能。

threading.Lock（）
返回新原始鎖定對(duì)象的工廠(chǎng)函數(shù)。一旦線(xiàn)程獲得它，后續(xù)嘗試獲取它就會(huì)阻塞，直到它被釋放; 任何線(xiàn)程都可以釋放它。

請(qǐng)參見(jiàn)鎖定對(duì)象。

threading.RLock（）
返回新的可重入鎖定對(duì)象的工廠(chǎng)函數(shù)。必須由獲取它的線(xiàn)程釋放重入鎖。一旦線(xiàn)程獲得了可重入鎖，同一個(gè)線(xiàn)程可以再次獲取它而不會(huì)阻塞; 線(xiàn)程必須在每次獲取它時(shí)釋放一次。

請(qǐng)參閱RLock對(duì)象。

threading.Semaphore（[ 值] ）
返回新信號(hào)量對(duì)象的工廠(chǎng)函數(shù)。信號(hào)量管理一個(gè)計(jì)數(shù)器，表示release()呼叫數(shù)減去acquire()呼叫數(shù) 加上初始值。該acquire()方法在必要時(shí)阻止，直到它可以返回而不使計(jì)數(shù)器為負(fù)。如果沒(méi)有給出，則值默認(rèn)為1。

請(qǐng)參見(jiàn)信號(hào)量對(duì)象。

threading.BoundedSemaphore（[ 值] ）
返回新的有界信號(hào)量對(duì)象的工廠(chǎng)函數(shù)。有界信號(hào)量檢查以確保其當(dāng)前值不超過(guò)其初始值。如果確實(shí)如此，ValueError則被提出。在大多數(shù)情況下，信號(hào)量用于保護(hù)容量有限的資源。如果信號(hào)量被釋放太多次，則表明存在錯(cuò)誤。如果沒(méi)有給出，則值默認(rèn)為1。

類(lèi) threading.Thread
表示控制線(xiàn)程的類(lèi)。該類(lèi)可以以有限的方式安全地進(jìn)行子類(lèi)化。

請(qǐng)參見(jiàn)線(xiàn)程對(duì)象。

類(lèi) threading.Timer
在指定的時(shí)間間隔過(guò)后執(zhí)行函數(shù)的線(xiàn)程。

見(jiàn)Timer對(duì)象。

threading.settrace（func ）
為從threading模塊啟動(dòng)的所有線(xiàn)程設(shè)置跟蹤功能。在調(diào)用sys.settrace()其run()方法之前，將為每個(gè)線(xiàn)程傳遞 func。

版本2.3中的新功能。

threading.setprofile（func ）
為從threading模塊啟動(dòng)的所有線(xiàn)程設(shè)置配置文件功能。在調(diào)用sys.setprofile()其run()方法之前，將為每個(gè)線(xiàn)程傳遞 func。

版本2.3中的新功能。

threading.stack_size（[ 大小] ）
返回創(chuàng)建新線(xiàn)程時(shí)使用的線(xiàn)程堆棧大小?？蛇x的 size參數(shù)指定用于后續(xù)創(chuàng)建的線(xiàn)程的堆棧大小，并且必須為0（使用平臺(tái)或已配置的默認(rèn)值）或至少為32,768（32 KiB）的正整數(shù)值。如果未指定size，則使用0。如果不支持更改線(xiàn)程堆棧大小，ThreadError則引發(fā)a。如果指定的堆棧大小無(wú)效，則aValueError被提升，堆棧大小未經(jīng)修改。32kB是目前支持的最小堆棧大小值，以保證解釋器本身有足夠的堆?？臻g。請(qǐng)注意，某些平臺(tái)可能對(duì)堆棧大小的值有特定限制，例如要求最小堆棧大小> 32kB或需要以系統(tǒng)內(nèi)存頁(yè)面大小的倍數(shù)進(jìn)行分配 - 應(yīng)提供平臺(tái)文檔以獲取更多信息（4kB頁(yè)面是常見(jiàn)的;在沒(méi)有更具體的信息的情況下，建議的方法是使用4096的倍數(shù)作為堆棧大小?？捎眯裕篧indows，具有POSIX線(xiàn)程的系統(tǒng)。

2.5版中的新功能。

異常threading.ThreadError
針對(duì)各種與線(xiàn)程相關(guān)的錯(cuò)誤提出，如下所述。請(qǐng)注意，許多接口使用RuntimeError而不是ThreadError。

下面記錄了對(duì)象的詳細(xì)界面。

該模塊的設(shè)計(jì)基于Java的線(xiàn)程模型。但是，在Java使鎖和條件變量成為每個(gè)對(duì)象的基本行為的地方，它們是Python中的獨(dú)立對(duì)象。Python的Thread類(lèi)支持Java的Thread類(lèi)的行為的子集; 目前，沒(méi)有優(yōu)先級(jí)，沒(méi)有線(xiàn)程組，線(xiàn)程不能被銷(xiāo)毀，停止，暫停，恢復(fù)或中斷。Java的Thread類(lèi)的靜態(tài)方法在實(shí)現(xiàn)時(shí)會(huì)映射到模塊級(jí)函數(shù)。

下面描述的所有方法都是原子執(zhí)行的。

線(xiàn)程對(duì)象

此類(lèi)表示在單獨(dú)的控制線(xiàn)程中運(yùn)行的活動(dòng)。有兩種方法可以指定活動(dòng)：將可調(diào)用對(duì)象傳遞給構(gòu)造函數(shù)，或者通過(guò)覆蓋run()子類(lèi)中的方法。不應(yīng)在子類(lèi)中重寫(xiě)其他方法（構(gòu)造函數(shù)除外）。換句話(huà)說(shuō)，只覆蓋此類(lèi)的init()和run()方法。

創(chuàng)建線(xiàn)程對(duì)象后，必須通過(guò)調(diào)用線(xiàn)程的start()方法啟動(dòng)其活動(dòng)。這將run()在單獨(dú)的控制線(xiàn)程中調(diào)用該方法。

一旦線(xiàn)程的活動(dòng)開(kāi)始，線(xiàn)程就被認(rèn)為是“活著的”。當(dāng)它的run()方法終止時(shí)，它會(huì)停止活動(dòng)- 通常，或者通過(guò)引發(fā)未處理的異常。該is_alive()方法測(cè)試線(xiàn)程是否存活。

其他線(xiàn)程可以調(diào)用線(xiàn)程的join()方法。這會(huì)阻塞調(diào)用線(xiàn)程，直到調(diào)用其join()方法的線(xiàn)程終止。

線(xiàn)程有一個(gè)名字。名稱(chēng)可以傳遞給構(gòu)造函數(shù)，并通過(guò)name屬性讀取或更改。

線(xiàn)程可以標(biāo)記為“守護(hù)程序線(xiàn)程”。這個(gè)標(biāo)志的意義在于當(dāng)只剩下守護(hù)進(jìn)程線(xiàn)程時(shí)整個(gè)Python程序退出。初始值繼承自創(chuàng)建線(xiàn)程?？梢酝ㄟ^(guò)daemon酒店設(shè)置標(biāo)志。

注意：守護(hù)程序線(xiàn)程在關(guān)閉時(shí)突然停止。他們的資源（例如打開(kāi)文件，數(shù)據(jù)庫(kù)事務(wù)等）可能無(wú)法正確發(fā)布。如果您希望線(xiàn)程正常停止，請(qǐng)使它們成為非守護(hù)進(jìn)程并使用合適的信令機(jī)制，例如Event。

有一個(gè)“主線(xiàn)程”對(duì)象; 這對(duì)應(yīng)于Python程序中的初始控制線(xiàn)程。它不是守護(hù)程序線(xiàn)程。

有可能創(chuàng)建“虛擬線(xiàn)程對(duì)象”。這些是與“外部線(xiàn)程”相對(duì)應(yīng)的線(xiàn)程對(duì)象，它們是在線(xiàn)程模塊外部啟動(dòng)的控制線(xiàn)程，例如直接來(lái)自C代碼。虛擬線(xiàn)程對(duì)象具有有限的功能; 他們總是被認(rèn)為是活著的和守護(hù)的，不能被join()編輯。它們永遠(yuǎn)不會(huì)被刪除，因?yàn)闊o(wú)法檢測(cè)外來(lái)線(xiàn)程的終止。

class threading.Thread（group = None，target = None，name = None，args =（），kwargs = {} ）
應(yīng)始終使用關(guān)鍵字參數(shù)調(diào)用此構(gòu)造函數(shù)。參數(shù)是：

小組應(yīng)該None; 在實(shí)現(xiàn)ThreadGroup類(lèi)時(shí)為將來(lái)的擴(kuò)展保留。

target是run()方法調(diào)用的可調(diào)用對(duì)象。默認(rèn)為None，意味著什么都沒(méi)有被調(diào)用。

name是線(xiàn)程名稱(chēng)。默認(rèn)情況下，唯一名稱(chēng)由“Thread- N ” 形式構(gòu)成，其中N是小十進(jìn)制數(shù)。

args是目標(biāo)調(diào)用的參數(shù)元組。默認(rèn)為()。

kwargs是目標(biāo)調(diào)用的關(guān)鍵字參數(shù)字典。默認(rèn)為{}。

如果子類(lèi)重寫(xiě)構(gòu)造函數(shù)，則必須確保Thread.init()在對(duì)線(xiàn)程執(zhí)行任何其他操作之前調(diào)用基類(lèi)構(gòu)造函數(shù)（）。
start（）
開(kāi)始線(xiàn)程的活動(dòng)。

每個(gè)線(xiàn)程對(duì)象最多只能調(diào)用一次。它安排run()在單獨(dú)的控制線(xiàn)程中調(diào)用對(duì)象的方法。

此方法將RuntimeError在同一個(gè)線(xiàn)程對(duì)象上多次調(diào)用if。

run（）
表示線(xiàn)程活動(dòng)的方法。

您可以在子類(lèi)中重寫(xiě)此方法。標(biāo)準(zhǔn)run() 方法調(diào)用傳遞給對(duì)象構(gòu)造函數(shù)的可調(diào)用對(duì)象作為目標(biāo)參數(shù)（如果有），分別使用args和kwargs參數(shù)中的順序和關(guān)鍵字參數(shù)。

join（[ 超時(shí)] ）
等到線(xiàn)程終止。這將阻塞調(diào)用線(xiàn)程，直到調(diào)用其join()方法的線(xiàn)程終止 - 正?；蛲ㄟ^(guò)未處理的異常 - 或直到發(fā)生可選的超時(shí)。

當(dāng)超時(shí)參數(shù)存在而不存在時(shí)None，它應(yīng)該是一個(gè)浮點(diǎn)數(shù)，指定操作的超時(shí)（以秒為單位）（或其中的分?jǐn)?shù)）。由于join()總是返回None，必須調(diào)用isAlive()后join()決定超時(shí)是否發(fā)生了-如果線(xiàn)程還活著時(shí)，join()調(diào)用超時(shí)。

當(dāng)timeout參數(shù)不存在時(shí)None，操作將阻塞，直到線(xiàn)程終止。

線(xiàn)程可以join()多次編輯。

join()提出了RuntimeError如果試圖加入當(dāng)前線(xiàn)程因?yàn)檫@將導(dǎo)致死鎖。join()在線(xiàn)程啟動(dòng)之前它也是一個(gè)錯(cuò)誤，并且嘗試這樣做會(huì)引發(fā)相同的異常。

name
字符串僅用于識(shí)別目的。它沒(méi)有語(yǔ)義。多個(gè)線(xiàn)程可以賦予相同的名稱(chēng)。初始名稱(chēng)由構(gòu)造函數(shù)設(shè)置。

版本2.6中的新功能。

getName（）
setName（）
適用于2.6之前的API name。

ident
此線(xiàn)程的“線(xiàn)程標(biāo)識(shí)符”或者None線(xiàn)程尚未啟動(dòng)。這是一個(gè)非零整數(shù)?？?thread.get_ident()功能。當(dāng)線(xiàn)程退出并創(chuàng)建另一個(gè)線(xiàn)程時(shí)，可以回收線(xiàn)程標(biāo)識(shí)符。即使在線(xiàn)程退出后，該標(biāo)識(shí)符也可用。

版本2.6中的新功能。

is_alive（）
isAlive（）
返回線(xiàn)程是否存活。

此方法True在run()方法啟動(dòng)之前返回，直到run()方法終止之后。模塊函數(shù) enumerate()返回所有活動(dòng)線(xiàn)程的列表。

在2.6版中更改：添加了is_alive()拼寫(xiě)。

daemon
一個(gè)布爾值，指示此線(xiàn)程是否為守護(hù)程序線(xiàn)程（True）或不是（False）。必須在start()調(diào)用之前設(shè)置，否則RuntimeError引發(fā)。它的初始值繼承自創(chuàng)建線(xiàn)程; 主線(xiàn)程不是守護(hù)程序線(xiàn)程，因此在主線(xiàn)程中創(chuàng)建的所有線(xiàn)程都默認(rèn)為daemon = False。

當(dāng)沒(méi)有剩下活著的非守護(hù)進(jìn)程線(xiàn)程時(shí)，整個(gè)Python程序退出。

版本2.6中的新功能。

isDaemon（）
setDaemon（）
適用于2.6之前的API daemon。

鎖定對(duì)象

原始鎖是一種同步原語(yǔ)，在鎖定時(shí)不屬于特定線(xiàn)程。在Python中，它是目前可用的最低級(jí)同步原語(yǔ)，由thread 擴(kuò)展模塊直接實(shí)現(xiàn)。

原始鎖定處于“鎖定”或“解鎖”兩種狀態(tài)之一。它是在解鎖狀態(tài)下創(chuàng)建的。它有兩種基本方法，acquire()和 release()。當(dāng)狀態(tài)解鎖時(shí)，acquire()將狀態(tài)更改為鎖定并立即返回。當(dāng)狀態(tài)被鎖定時(shí)，acquire() 阻塞直到release()另一個(gè)線(xiàn)程中的調(diào)用將其更改為解鎖，然后該acquire()調(diào)用將其重置為已鎖定并返回。該 release()方法只應(yīng)在鎖定狀態(tài)下調(diào)用; 它將狀態(tài)更改為已解鎖并立即返回。如果嘗試釋放未鎖定的鎖，ThreadError則會(huì)引發(fā)a。

當(dāng)acquire()等待狀態(tài)轉(zhuǎn)為解鎖時(shí)阻塞多個(gè)線(xiàn)程時(shí)，只有一個(gè)線(xiàn)程在release()呼叫重置狀態(tài)解鎖時(shí)繼續(xù); 哪個(gè)等待線(xiàn)程繼續(xù)進(jìn)行未定義，并且可能因?qū)崿F(xiàn)而異。

所有方法都以原子方式執(zhí)行。

Lock.acquire（[ 阻止] ）
獲取鎖定，阻止或非阻止。

當(dāng)阻塞參數(shù)設(shè)置為T(mén)rue（默認(rèn)值）時(shí)調(diào)用，阻塞直到解鎖，然后將其設(shè)置為鎖定并返回True。

在使用阻塞參數(shù)設(shè)置為的情況下調(diào)用時(shí)False，請(qǐng)勿阻止。如果一個(gè)帶阻塞的調(diào)用設(shè)置為T(mén)rue阻塞，則False 立即返回; 否則，將鎖定設(shè)置為鎖定并返回True。

Lock.release（）
解鎖。

鎖定鎖定后，將其重置為解鎖狀態(tài)，然后返回。如果阻止任何其他線(xiàn)程等待鎖解鎖，則只允許其中一個(gè)繼續(xù)執(zhí)行。

在未鎖定的鎖上調(diào)用時(shí)，ThreadError會(huì)引發(fā)a。

沒(méi)有回報(bào)價(jià)值。

RLock對(duì)象

可重入鎖是同步原語(yǔ)，可以由同一線(xiàn)程多次獲取。在內(nèi)部，除了原始鎖使用的鎖定/解鎖狀態(tài)之外，它還使用“擁有線(xiàn)程”和“遞歸級(jí)別”的概念。在鎖定狀態(tài)下，某些線(xiàn)程擁有鎖; 在解鎖狀態(tài)下，沒(méi)有線(xiàn)程擁有它。

要鎖定鎖，線(xiàn)程會(huì)調(diào)用其acquire()方法; 一旦線(xiàn)程擁有鎖，它就會(huì)返回。要解鎖鎖，線(xiàn)程會(huì)調(diào)用其 release()方法。acquire()/ release()call對(duì)可以嵌套; 只有最后一個(gè)release()（release()最外面的一對(duì)）重置鎖才能解鎖并允許另一個(gè)被阻塞的線(xiàn)程 acquire()繼續(xù)進(jìn)行。

RLock.acquire（[ blocking = 1 ] ）
獲取鎖定，阻止或非阻止。

在不帶參數(shù)的情況下調(diào)用：如果此線(xiàn)程已擁有鎖，則將遞歸級(jí)別遞增1，并立即返回。否則，如果另一個(gè)線(xiàn)程擁有該鎖，則阻塞直到鎖被解鎖。鎖解鎖后（不屬于任何線(xiàn)程），然后獲取所有權(quán)，將遞歸級(jí)別設(shè)置為1，然后返回。如果多個(gè)線(xiàn)程被阻塞等待鎖解鎖，則一次只能有一個(gè)線(xiàn)程獲取鎖的所有權(quán)。在這種情況下沒(méi)有返回值。

在將blocking參數(shù)設(shè)置為true的情況下調(diào)用時(shí)，執(zhí)行與不帶參數(shù)調(diào)用時(shí)相同的操作，并返回true。

在將blocking參數(shù)設(shè)置為false的情況下調(diào)用時(shí)，請(qǐng)勿阻止。如果沒(méi)有參數(shù)的調(diào)用會(huì)阻塞，則立即返回false; 否則，執(zhí)行與不帶參數(shù)調(diào)用時(shí)相同的操作，并返回true。

RLock.release（）
釋放鎖定，遞減遞歸級(jí)別。如果在遞減之后它為零，則將鎖重置為未鎖定（不由任何線(xiàn)程擁有），并且如果阻止任何其他線(xiàn)程等待鎖解鎖，則允許其中一個(gè)繼續(xù)進(jìn)行。如果在遞減之后遞歸級(jí)別仍然非零，則鎖保持鎖定并由調(diào)用線(xiàn)程擁有。

僅在調(diào)用線(xiàn)程擁有鎖時(shí)調(diào)用此方法。RuntimeError如果在鎖定解鎖時(shí)調(diào)用此方法，則引發(fā)A.

沒(méi)有回報(bào)價(jià)值。

條件對(duì)象

條件變量總是與某種鎖相關(guān)聯(lián); 這可以傳入，或者默認(rèn)創(chuàng)建一個(gè)。（當(dāng)多個(gè)條件變量必須共享同一個(gè)鎖時(shí)，傳入一個(gè)是有用的。）

條件變量具有acquire()與release()該調(diào)用相關(guān)聯(lián)的鎖的相應(yīng)方法的方法。它還有一種wait() 方法notify()和notifyAll()方法。只有在調(diào)用線(xiàn)程獲得鎖定時(shí)才調(diào)用這三個(gè)，否則 RuntimeError引發(fā)a。

該wait()方法釋放鎖，然后阻塞，直到它被另一個(gè)線(xiàn)程中的相同條件變量喚醒notify()或notifyAll()調(diào)用。一旦被喚醒，它就會(huì)重新獲得鎖并返回。也可以指定超時(shí)。

該notify()方法喚醒等待條件變量的其中一個(gè)線(xiàn)程，如果有的話(huà)正在等待。該notifyAll()方法喚醒等待條件變量的所有線(xiàn)程。

注意：notify()和notifyAll()方法不釋放鎖; 這意味著被喚醒的一個(gè)或多個(gè)線(xiàn)程不會(huì)wait()立即從它們的調(diào)用返回，而是僅在調(diào)用notify()或notifyAll()最終放棄鎖的所有權(quán)的線(xiàn)程時(shí) 返回。

提示：使用條件變量的典型編程風(fēng)格使用鎖來(lái)同步對(duì)某些共享狀態(tài)的訪(fǎng)問(wèn); 對(duì)狀態(tài)的特定變化感興趣的線(xiàn)程wait()重復(fù)調(diào)用，直到它們看到所需的狀態(tài)，而線(xiàn)程修改狀態(tài)調(diào)用notify()或者 notifyAll()當(dāng)它們改變狀態(tài)時(shí)它可能是其中一個(gè)服務(wù)員的期望狀態(tài)。例如，以下代碼是具有無(wú)限緩沖區(qū)容量的通用生產(chǎn)者 - 消費(fèi)者情況：

# Consume one item
cv.acquire()
while not an_item_is_available():
  cv.wait()
get_an_available_item()
cv.release()

# Produce one item
cv.acquire()
make_an_item_available()
cv.notify()
cv.release()

要在notify()和之間進(jìn)行選擇notifyAll()，請(qǐng)考慮一個(gè)狀態(tài)更改是否只對(duì)一個(gè)或多個(gè)等待線(xiàn)程感興趣。例如，在典型的生產(chǎn)者 - 消費(fèi)者情況下，向緩沖區(qū)添加一個(gè)項(xiàng)目只需要喚醒一個(gè)消費(fèi)者線(xiàn)程。

class threading.Condition（[ lock ] ）
如果給出了lock參數(shù)None，則它必須是一個(gè)Lock 或RLock對(duì)象，并且它被用作底層鎖。否則，將RLock創(chuàng)建一個(gè)新對(duì)象并將其用作基礎(chǔ)鎖。

acquire（* args ）
獲取底層鎖。此方法在底層鎖上調(diào)用相應(yīng)的方法; 返回值是該方法返回的任何值。

release（）
釋放底層鎖。此方法在底層鎖上調(diào)用相應(yīng)的方法; 沒(méi)有回報(bào)價(jià)值。

wait（[ 超時(shí)] ）
等到通知或直到發(fā)生超時(shí)。如果在調(diào)用此方法時(shí)調(diào)用線(xiàn)程尚未獲取鎖定，RuntimeError則引發(fā)a。

此方法釋放底層鎖，然后阻塞，直到它被另一個(gè)線(xiàn)程中的相同條件變量喚醒notify()或notifyAll()調(diào)用，或者直到發(fā)生可選超時(shí)。一旦被喚醒或超時(shí)，它就會(huì)重新獲得鎖定并返回。

當(dāng)超時(shí)參數(shù)存在而不存在時(shí)None，它應(yīng)該是一個(gè)浮點(diǎn)數(shù)，指定操作的超時(shí)（以秒為單位）（或其中的分?jǐn)?shù)）。

當(dāng)?shù)讓渔i是a時(shí)RLock，它不會(huì)使用其release()方法釋放，因?yàn)楫?dāng)遞歸多次獲取鎖時(shí)，這實(shí)際上可能無(wú)法解鎖。相反，使用了RLock類(lèi)的內(nèi)部接口，即使多次遞歸獲取它也能真正解鎖它。然后，在重新獲取鎖時(shí)，使用另一個(gè)內(nèi)部接口來(lái)恢復(fù)遞歸級(jí)別。

notify（n = 1 ）
默認(rèn)情況下，喚醒一個(gè)等待此條件的線(xiàn)程（如果有）。如果在調(diào)用此方法時(shí)調(diào)用線(xiàn)程尚未獲取鎖定， RuntimeError則引發(fā)a。

此方法最多喚醒等待條件變量的n個(gè)線(xiàn)程; 如果沒(méi)有線(xiàn)程在等待，那么這是一個(gè)無(wú)操作。

如果至少有n個(gè) 線(xiàn)程在等待，那么當(dāng)前的實(shí)現(xiàn)只會(huì)喚醒n 個(gè)線(xiàn)程。但是，依靠這種行為是不安全的。未來(lái)的優(yōu)化實(shí)現(xiàn)有時(shí)可能會(huì)喚醒超過(guò) n個(gè)線(xiàn)程。

注意：?jiǎn)拘丫€(xiàn)程實(shí)際上不會(huì)從其wait() 調(diào)用返回，直到它可以重新獲取鎖定。由于notify()不釋放鎖，其調(diào)用者應(yīng)該。

notify_all（）
notifyAll（）
喚醒等待這種情況的所有線(xiàn)程。這種方法就像 notify()，但喚醒所有等待的線(xiàn)程而不是一個(gè)。如果在調(diào)用此方法時(shí)調(diào)用線(xiàn)程尚未獲取鎖定， RuntimeError則引發(fā)a。

在2.6版中更改：添加了notify_all()拼寫(xiě)。

信號(hào)量對(duì)象

這是計(jì)算機(jī)科學(xué)史上最古老的同步原語(yǔ)之一，由早期的荷蘭計(jì)算機(jī)科學(xué)家Edsger W. Dijkstra（他使用P()而V()不是acquire()和release()）發(fā)明。

信號(hào)量管理一個(gè)內(nèi)部計(jì)數(shù)器，該計(jì)數(shù)器按每次acquire()調(diào)用遞減并按每次調(diào)用遞增release()。計(jì)數(shù)器永遠(yuǎn)不會(huì)低于零; 當(dāng)acquire()發(fā)現(xiàn)它為零時(shí)，它會(huì)阻塞，等待其他線(xiàn)程調(diào)用release()。

class threading.Semaphore（[ value ] ）
可選參數(shù)給出內(nèi)部計(jì)數(shù)器的初始值 ; 它默認(rèn)為1。如果給定的值小于0，ValueError則引發(fā)。

acquire（[ 阻止] ）
獲取信號(hào)量。

在不帶參數(shù)的情況下調(diào)用：如果內(nèi)部計(jì)數(shù)器在輸入時(shí)大于零，則將其減1并立即返回。如果在進(jìn)入時(shí)為零，則阻塞，等待其他線(xiàn)程調(diào)用 release()以使其大于零。這是通過(guò)適當(dāng)?shù)幕ユi來(lái)完成的，這樣如果多個(gè)acquire()呼叫被阻止，它們 release()將完全喚醒其中一個(gè)。實(shí)現(xiàn)可以隨機(jī)選擇一個(gè)，因此不應(yīng)該依賴(lài)被阻塞的線(xiàn)程被喚醒的順序。在這種情況下沒(méi)有返回值。

當(dāng)使用blocking設(shè)置為true 調(diào)用時(shí)，執(zhí)行與不帶參數(shù)調(diào)用時(shí)相同的操作，并返回true。

當(dāng)阻塞設(shè)置為false 時(shí)調(diào)用，請(qǐng)勿阻止。如果沒(méi)有參數(shù)的調(diào)用會(huì)阻塞，則立即返回false; 否則，執(zhí)行與不帶參數(shù)調(diào)用時(shí)相同的操作，并返回true。

release（）
釋放信號(hào)量，將內(nèi)部計(jì)數(shù)器遞增1。當(dāng)它在進(jìn)入時(shí)為零并且另一個(gè)線(xiàn)程正在等待它再次大于零時(shí)，喚醒該線(xiàn)程。

Semaphore示例

信號(hào)量通常用于保護(hù)容量有限的資源，例如數(shù)據(jù)庫(kù)服務(wù)器。在資源大小固定的任何情況下，您應(yīng)該使用有界信號(hào)量。在產(chǎn)生任何工作線(xiàn)程之前，您的主線(xiàn)程將初始化信號(hào)量：

maxconnections = 5
...
pool_sema = BoundedSemaphore(value=maxconnections)

一旦產(chǎn)生，工作線(xiàn)程在需要連接到服務(wù)器時(shí)調(diào)用信號(hào)量的獲取和釋放方法：

pool_sema.acquire()
conn = connectdb()
... use connection ...
conn.close()
pool_sema.release()

有界信號(hào)量的使用減少了導(dǎo)致信號(hào)量被釋放的編程錯(cuò)誤超過(guò)其獲取的編程錯(cuò)誤的可能性。

事件對(duì)象

這是線(xiàn)程之間通信的最簡(jiǎn)單機(jī)制之一：一個(gè)線(xiàn)程發(fā)出事件信號(hào)，其他線(xiàn)程等待它。

事件對(duì)象管理一個(gè)內(nèi)部標(biāo)志，該標(biāo)志可以使用該set()方法設(shè)置為true，并使用該方法重置為false clear() 。該wait()方法將阻塞，直到該標(biāo)志為真。

類(lèi)threading.Event
內(nèi)部標(biāo)志最初是假的。

is_set（）
isSet（）
當(dāng)且僅當(dāng)內(nèi)部標(biāo)志為真時(shí)返回true。

在2.6版中更改：添加了is_set()拼寫(xiě)。

set（）
將內(nèi)部標(biāo)志設(shè)置為true。等待它變?yōu)檎娴乃芯€(xiàn)程都被喚醒。wait()一旦標(biāo)志為真，調(diào)用的線(xiàn)程將不會(huì)阻塞。

clear（）
將內(nèi)部標(biāo)志重置為false。隨后，線(xiàn)程調(diào)用 wait()將阻塞，直到set()被調(diào)用以再次將內(nèi)部標(biāo)志設(shè)置為true。

wait（[ 超時(shí)] ）
阻止，直到內(nèi)部標(biāo)志為真。如果輸入時(shí)內(nèi)部標(biāo)志為真，則立即返回。否則，阻塞直到另一個(gè)線(xiàn)程調(diào)用 set()將標(biāo)志設(shè)置為true，或者直到發(fā)生可選的超時(shí)。

此方法在退出時(shí)返回內(nèi)部標(biāo)志，因此它將始終返回， True除非給出超時(shí)并且操作超時(shí)。

在2.7版中更改：以前，該方法始終返回None。

定時(shí)器對(duì)象

此類(lèi)表示應(yīng)該在經(jīng)過(guò)一定時(shí)間后運(yùn)行的操作 - 計(jì)時(shí)器。 Timer是一個(gè)子類(lèi)，Thread 因此也可以作為創(chuàng)建自定義線(xiàn)程的示例。

通過(guò)調(diào)用start() 方法，啟動(dòng)計(jì)時(shí)器，就像使用線(xiàn)程一樣。通過(guò)調(diào)用cancel()方法可以停止計(jì)時(shí)器（在其動(dòng)作開(kāi)始之前）。計(jì)時(shí)器在執(zhí)行其操作之前將等待的時(shí)間間隔可能與用戶(hù)指定的時(shí)間間隔不完全相同。

例如：

def hello():
  print "hello, world"

t = Timer(30.0, hello)
t.start() # after 30 seconds, "hello, world" will be printed

class threading.Timer（interval，function，args = []，kwargs = {} ）
創(chuàng)建一個(gè)計(jì)時(shí)器，在經(jīng)過(guò)間隔秒后，將使用參數(shù)args和關(guān)鍵字參數(shù)kwargs運(yùn)行函數(shù)。

cancel（）
停止計(jì)時(shí)器，取消執(zhí)行計(jì)時(shí)器的操作。這只有在計(jì)時(shí)器仍處于等待階段時(shí)才有效。

在with語(yǔ)句中使用鎖，條件和信號(hào)量

此模塊提供的具有acquire()和 release()方法的所有對(duì)象都可以用作with 語(yǔ)句的上下文管理器。acquire()進(jìn)入塊時(shí)將調(diào)用該方法，并release()在退出塊時(shí)調(diào)用該方法。

目前Lock，RLock，Condition， Semaphore，和BoundedSemaphore對(duì)象可以用作 with聲明上下文管理。例如：

import threading

some_rlock = threading.RLock()

with some_rlock:
  print "some_rlock is locked while this executes"

在線(xiàn)程代碼中導(dǎo)入

雖然導(dǎo)入機(jī)制是線(xiàn)程安全的，但由于提供線(xiàn)程安全的方式存在固有限制，因此線(xiàn)程導(dǎo)入有兩個(gè)主要限制：

首先，除了在主模塊中，導(dǎo)入不應(yīng)該產(chǎn)生產(chǎn)生新線(xiàn)程然后以任何方式等待該線(xiàn)程的副作用。如果生成的線(xiàn)程直接或間接嘗試導(dǎo)入模塊，則不遵守此限制可能導(dǎo)致死鎖。
其次，所有導(dǎo)入嘗試必須在解釋器開(kāi)始關(guān)閉之前完成。僅通過(guò)從通過(guò)線(xiàn)程模塊創(chuàng)建的非守護(hù)程序線(xiàn)程執(zhí)行導(dǎo)入，可以最容易地實(shí)現(xiàn)這一點(diǎn)。直接使用線(xiàn)程模塊創(chuàng)建的守護(hù)程序線(xiàn)程和線(xiàn)程將需要一些其他形式的同步，以確保在系統(tǒng)關(guān)閉開(kāi)始后它們不會(huì)嘗試導(dǎo)入。不遵守此限制將導(dǎo)致在解釋器關(guān)閉期間出現(xiàn)間歇性異常和崩潰（因?yàn)楹笃趯?dǎo)入嘗試訪(fǎng)問(wèn)不再處于有效狀態(tài)的機(jī)器）。

希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: