文章目錄

• 一、前言
• 二、創(chuàng)建兩個(gè)同時(shí)運(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ā)，即同一時(shí)刻只有一個(gè)線程在運(yùn)行。據(jù)說python后來想將這個(gè)假的“并發(fā)”改為真的并發(fā)，但出現(xiàn)特別多的BUG，最后放棄了這個(gè)想法。

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

python多線程與單片機(jī)的RTOS在調(diào)度規(guī)則完全不一樣。python多線程的調(diào)度程序會在任何時(shí)候中斷線程（相當(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)度程序任何時(shí)候都可能中斷線程。必須記住保留鎖，去保護(hù)程序中的重要部分，防止多步操作在執(zhí)行的過程中被中斷，防止數(shù)據(jù)處于無效狀態(tài)。 —《流暢的Python》- Luciano Ramalho

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

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

---

2.1、代碼

# python3.9 import time import threadingdef thread1():"""線程1"""while True:# 打印信息，并打印性能計(jì)數(shù)器的值print("I am thread1，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def thread2():"""線程2"""while True:# 打印信息，并打印性能計(jì)數(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秒時(shí)間運(yùn)行一次。線程1與線程2哪個(gè)先運(yùn)行取決于系統(tǒng)的調(diào)度。

三、threading庫的函數(shù)

---

3.1、threading.Thread()

入口參數(shù)：

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

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

運(yùn)行代碼：

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

運(yùn)行代碼：

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

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

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

3.2、threading.join()

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

3.3、threading.start()

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

四、最終的完整代碼

---

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

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

# python3.9 import time import threadingdef thread1():"""線程1"""while True:# 打印信息，并打印性能計(jì)數(shù)器的值print("I am thread1，time is %f" % time.perf_counter())time.sleep(1) # 休眠1秒def thread2():"""線程2"""while True:# 打印信息，并打印性能計(jì)數(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)容還不錯(cuò)，歡迎將生活随笔推薦給好友。