python中的執行緒threading.Thread()使用詳解
1. 執行緒的概念:
執行緒,有時被稱為輕量級程序(Lightweight Process,LWP),是程式執行流的最小單元。一個標準的執行緒由執行緒ID,當前指令指標(PC),暫存器集合和堆疊組成。另外,執行緒是程序中的一個實體,是被系統獨立排程和分派的基本單位,執行緒自己不擁有系統資源,只擁有一點兒在執行中必不可少的資源,但它可與同屬一個程序的其它執行緒共享程序所擁有的全部資源。
2. threading.thread()的簡單使用
2.1 python的thread模組是比較底層的模組,python的threading模組是對thread做了一些包裝的,可以更加方便的被使用
import threading import time def saySorry(): print("親愛的,我錯了,我能吃飯了嗎?") time.sleep(1) if __name__ == "__main__": for i in range(5): t = threading.Thread(target=saySorry) t.start() #啟動執行緒,即讓執行緒開始執行
執行結果:
使用說明:
- 可以明顯看出使用了多執行緒併發的操作,花費時間要短很多
- 當呼叫start()時,才會真正的建立執行緒,並且開始執行
- 每個執行緒都有一個唯一標示符,來區分執行緒中的主次關係
- 主執行緒:mainThread,Main函式或者程式主入口,都可以稱為主執行緒
- 子執行緒:Thread-x 使用 threading.Thread() 創建出來的都是子執行緒
- 執行緒數量:主執行緒數 + 子執行緒數
2.2 主執行緒會等待所有的子執行緒結束後才結束
import threading from time import sleep,ctime def sing(): for i in range(3): print("正在唱歌...%d"%i) sleep(1) def dance(): for i in range(3): print("正在跳舞...%d"%i) sleep(1) if __name__ == '__main__': print('---開始---:%s'%ctime()) t1 = threading.Thread(target=sing) t2 = threading.Thread(target=dance) t1.start() t2.start() #sleep(5) # 遮蔽此行程式碼,試試看,程式是否會立馬結束? print('---結束---:%s'%ctime())
3.檢視執行緒數量
import threading from time import sleep,ctime def sing(): for i in range(3): print("正在唱歌...%d"%i) sleep(1) def dance(): for i in range(3): print("正在跳舞...%d"%i) sleep(1) if __name__ == '__main__': print('---開始---:%s'%ctime()) t1 = threading.Thread(target=sing) t2 = threading.Thread(target=dance) t1.start() t2.start() while True: length = len(threading.enumerate()) print('當前執行的執行緒數為:%d'%length) if length<=1: break sleep(0.5)
4.執行緒引數及順序
4.1 傳遞引數的方法:
- 使用args 傳遞引數 threading.Thread(target=sing,args=(10,100,100))
- 使用kwargs傳遞引數 threading.Thread(target=sing,kwargs={“a”: 10,“b”:100,“c”: 100})
- 同時使用 args 和 kwargs 傳遞引數 threading.Thread(target=sing,),kwargs={“b”: 100,“c”: 100})
4.2 執行緒的執行順序
import socket import threading import time def sing(): for i in range(10): print("------------------------------") time.sleep(0.5) def dance(): for i in range(10): print("-----") time.sleep(0.5) if __name__ == '__main__': # 建立兩個子執行緒 t1 = threading.Thread(target=sing) t2 = threading.Thread(target=dance) # 啟動子執行緒 t1.start() t2.start()
說明:
從程式碼和執行結果我們可以看出,多執行緒程式的執行順序是不確定的。當執行到sleep語句時,執行緒將被阻塞(Blocked),到sleep結束後,執行緒進入就緒(Runnable)狀態,等待排程。而執行緒排程將自行選擇一個執行緒執行。上面的程式碼中只能保證每個執行緒都執行完整個run函式,但是執行緒的啟動順序、run函式中每次迴圈的執行順序都不能確定。
5. 守護執行緒
守護執行緒:如果在程式中將子執行緒設定為守護執行緒,則該子執行緒會在主執行緒結束時自動退出,設定方式為thread.setDaemon(True),要在thread.start()之前設定,預設是false的,也就是主執行緒結束時,子執行緒依然在執行。
5.1 如下程式碼,主執行緒已經exit() 【其實並沒有真正結束】,子執行緒還在繼續執行
import threading import time def test(): for i in range(10): print("test is run:",i) time.sleep(1) if __name__ == '__main__': # 建立子執行緒 t1 = threading.Thread(target=test) # 啟動子執行緒 t1.start() # 休眠2秒 time.sleep(2) print("我 OVER 了") # 退出 exit()
5.2 設定守護執行緒
設定為守護執行緒(如果主執行緒結束了,也隨之結束)
執行緒.setDaemon(True)
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。