python中的线程threading.Thread()使用
1. 線程的概念:
線程,有時被稱為輕量級進程(Lightweight Process,LWP),是程序執行流的最小單元。一個標準的線程由線程ID,當前指令指針(PC),寄存器集合和堆棧組成。另外,線程是進程中的一個實體,是被系統獨立調度和分派的基本單位,線程自己不擁有系統資源,只擁有一點兒在運行中必不可少的資源,但它可與同屬一個進程的其它線程共享進程所擁有的全部資源。
2. threading.thread()的簡單使用
2.1 python的thread模塊是比較底層的模塊,python的threading模塊是對thread做了一些包裝的,可以更加方便的被使用
import threading import timedef 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,ctimedef 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,ctimedef 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:breaksleep(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, args=(10, ), kwargs={“b”: 100,“c”: 100})
4.2 線程的執行順序
import socket import threading import timedef 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 timedef 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)
總結
以上是生活随笔為你收集整理的python中的线程threading.Thread()使用的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Python进程multiprocess
- 下一篇: Python OS和shutil模块的常