文章目錄

• 一、前言
• 二、創(chuàng)建兩個同時運(yùn)行的線程
• • 2.1、代碼
  • 2.2、運(yùn)行
• 三、threading庫的函數(shù)
• • 3.1、threading.Thread()
  • 3.2、threading.join()
  • 3.3、threading.start()
• 四、最終的完整代碼

一、前言

---

使用threading庫，咱們的python程序就能從單線程串行變成多線程并發(fā)。python的threading庫實(shí)現(xiàn)的“并發(fā)”是假的并發(fā)，即同一時刻只有一個線程在運(yùn)行。據(jù)說python后來想將這個假的“并發(fā)”改為真的并發(fā)，但出現(xiàn)特別多的BUG，最后放棄了這個想法。

聊到假的“并行”，學(xué)習(xí)過單片機(jī)（STM32)的嵌入式實(shí)時系統(tǒng)RTOS（ucosIII、freeRTOS、RTX5等）的同學(xué)就知道，移植了RTOS的單片機(jī)，同一時刻僅僅只有一個線程在運(yùn)行。只是RTOS在很快的切換線程，產(chǎn)生了好像多個線程在同時工作的“假象”。

python多線程與單片機(jī)的RTOS在調(diào)度規(guī)則完全不一樣。python多線程的調(diào)度程序會在任何時候中斷線程（相當(dāng)于調(diào)度，所以python多線程的調(diào)度可以說是很難控制的），單片機(jī)的RTOS會有相應(yīng)的API來產(chǎn)生調(diào)度（調(diào)度是可控的）。

線程與協(xié)程之間的比較還有最后一點(diǎn)要說明：如果使用線程做過重要的編程，就知道寫出程序有多么困難，因?yàn)檎{(diào)度程序任何時候都可能中斷線程。必須記住保留鎖，去保護(hù)程序中的重要部分，防止多步操作在執(zhí)行的過程中被中斷，防止數(shù)據(jù)處于無效狀態(tài)。 —《流暢的Python》- Luciano Ramalho

所以，在我看來：python的協(xié)程與單片機(jī)的RTOS才是相似的。

二、創(chuàng)建兩個同時運(yùn)行的線程

---

2.1、代碼

# python3.9 import time import threadingdef thread1():"""線程1"""while True:# 打印信息，并打印性能計數(shù)器的值print("I am thread1，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def thread2():"""線程2"""while True:# 打印信息，并打印性能計數(shù)器的值print("I am thread2，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def main():"""主線程"""t1 = threading.Thread(target=thread1) # 創(chuàng)建thread1線程t2 = threading.Thread(target=thread2) # 創(chuàng)建thread2線程t1.start() # 啟動thread1線程t2.start() # 啟動thread2線程if __name__ == "__main__":main()

2.2、運(yùn)行

從下圖可以看到，線程1與線程2都是每隔約1秒時間運(yùn)行一次。線程1與線程2哪個先運(yùn)行取決于系統(tǒng)的調(diào)度。

三、threading庫的函數(shù)

---

3.1、threading.Thread()

入口參數(shù)：

• group - 暫時不使用
• target - 用于執(zhí)行線程需要執(zhí)行的線程函數(shù)
• name - 可以自定義線程的名字，不設(shè)置的話，系統(tǒng)就自動分配
• args - 創(chuàng)建線程時，可以給線程函數(shù)傳遞參數(shù)
• kwargs - 暫時不使用
• daemon - 設(shè)置線程是否為守護(hù)線程（后臺線程）

當(dāng)我們不對入口參數(shù)name賦值的話，系統(tǒng)會自動分配線程名字。

運(yùn)行代碼：

接著，我嘗試對入口參數(shù)name進(jìn)行賦值。

運(yùn)行代碼：

另外一個重要的入口參數(shù)是daemon，它的作用是設(shè)置線程是否為守護(hù)線程（后臺線程）。守護(hù)線程有一個重要的特點(diǎn)是主線程（例子的main()線程）退出時，守護(hù)線程不管怎樣都要跟主線程一起退出。
守護(hù)線程的目的與作用：

所以，我的理解是：當(dāng)創(chuàng)建的子線程是無限循環(huán)的話，就應(yīng)該設(shè)置為守護(hù)線程。隨著主線程的退出，子線程被強(qiáng)制退出，保證了整個python程序正常地，完整地退出。

運(yùn)行結(jié)果：
main（）線程退出，線程t1與t2也跟著退出了。有什么辦法解決這個問題？

3.2、threading.join()

join()方法可以讓主線程進(jìn)入阻塞態(tài)，等待其他線程運(yùn)行結(jié)束，接著才解除阻塞態(tài)。

3.3、threading.start()

start()方法用于啟動線程的運(yùn)行，否則線程不會跑起來。

四、最終的完整代碼

---

使用守護(hù)線程，主線程退出時，強(qiáng)制讓所有的子線程退出，確保整個python程序正常地退出。

使用threading.join()方法，讓主線程等子線程結(jié)束，無限循環(huán)的子線程可以持續(xù)無限執(zhí)行。

# python3.9 import time import threadingdef thread1():"""線程1"""while True:# 打印信息，并打印性能計數(shù)器的值print("I am thread1，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def thread2():"""線程2"""while True:# 打印信息，并打印性能計數(shù)器的值print("I am thread2，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def main():"""主線程"""t1 = threading.Thread(target=thread1,name="fun_thread1",daemon=True) # 創(chuàng)建thread1線程t2 = threading.Thread(target=thread2,name="fun_thread2",daemon=True) # 創(chuàng)建thread2線程t1.start() # 啟動thread1線程t2.start() # 啟動thread2線程print("t1的線程名字是 %s" % t1.getName()) # 打印t1線程的線程名字print("t2的線程名字是 %s" % t2.getName()) # 打印t2線程的線程名字t1.join() # 當(dāng)前需要等待線程t1執(zhí)行完畢后才能運(yùn)行下一步t2.join() # 當(dāng)前需要等待線程t2執(zhí)行完畢后才能運(yùn)行下一步print("主線程執(zhí)行完畢！")if __name__ == "__main__":main()

總結(jié)

以上是生活随笔為你收集整理的Python | threading01 - 创建两个同时运行的子线程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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