python中的线程threading.Thread()使用
1. 線程的概念:
線程,有時(shí)被稱為輕量級(jí)進(jìn)程(Lightweight Process,LWP),是程序執(zhí)行流的最小單元。一個(gè)標(biāo)準(zhǔn)的線程由線程ID,當(dāng)前指令指針(PC),寄存器集合和堆棧組成。另外,線程是進(jìn)程中的一個(gè)實(shí)體,是被系統(tǒng)獨(dú)立調(diào)度和分派的基本單位,線程自己不擁有系統(tǒng)資源,只擁有一點(diǎn)兒在運(yùn)行中必不可少的資源,但它可與同屬一個(gè)進(jìn)程的其它線程共享進(jìn)程所擁有的全部資源。
2. threading.thread()的簡單使用
2.1 python的thread模塊是比較底層的模塊,python的threading模塊是對(duì)thread做了一些包裝的,可以更加方便的被使用
import threading import timedef saySorry():print("親愛的,我錯(cuò)了,我能吃飯了嗎?")time.sleep(1)if __name__ == "__main__":for i in range(5):t = threading.Thread(target=saySorry)t.start() #啟動(dòng)線程,即讓線程開始執(zhí)行運(yùn)行結(jié)果:
使用說明:
- 可以明顯看出使用了多線程并發(fā)的操作,花費(fèi)時(shí)間要短很多
- 當(dāng)調(diào)用start()時(shí),才會(huì)真正的創(chuàng)建線程,并且開始執(zhí)行
- 每個(gè)線程都有一個(gè)唯一標(biāo)示符,來區(qū)分線程中的主次關(guān)系
- 主線程:mainThread,Main函數(shù)或者程序主入口,都可以稱為主線程
- 子線程:Thread-x 使用 threading.Thread() 創(chuàng)建出來的都是子線程
- 線程數(shù)量:主線程數(shù) + 子線程數(shù)
2.2 主線程會(huì)等待所有的子線程結(jié)束后才結(jié)束
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) # 屏蔽此行代碼,試試看,程序是否會(huì)立馬結(jié)束?print('---結(jié)束---:%s'%ctime())3.查看線程數(shù)量
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āng)前運(yùn)行的線程數(shù)為:%d'%length)if length<=1:breaksleep(0.5)4.線程參數(shù)及順序
4.1 傳遞參數(shù)的方法:
- 使用args 傳遞參數(shù) threading.Thread(target=sing, args=(10, 100, 100))
- 使用kwargs傳遞參數(shù) threading.Thread(target=sing, kwargs={“a”: 10, “b”:
100, “c”: 100}) - 同時(shí)使用 args 和 kwargs 傳遞參數(shù) threading.Thread(target=sing, args=(10, ), kwargs={“b”: 100,“c”: 100})
4.2 線程的執(zhí)行順序
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__':# 創(chuàng)建兩個(gè)子線程t1 = threading.Thread(target=sing)t2 = threading.Thread(target=dance)# 啟動(dòng)子線程t1.start()t2.start()說明:
從代碼和執(zhí)行結(jié)果我們可以看出,多線程程序的執(zhí)行順序是不確定的。當(dāng)執(zhí)行到sleep語句時(shí),線程將被阻塞(Blocked),到sleep結(jié)束后,線程進(jìn)入就緒(Runnable)狀態(tài),等待調(diào)度。而線程調(diào)度將自行選擇一個(gè)線程執(zhí)行。上面的代碼中只能保證每個(gè)線程都運(yùn)行完整個(gè)run函數(shù),但是線程的啟動(dòng)順序、run函數(shù)中每次循環(huán)的執(zhí)行順序都不能確定。
5. 守護(hù)線程
守護(hù)線程:如果在程序中將子線程設(shè)置為守護(hù)線程,則該子線程會(huì)在主線程結(jié)束時(shí)自動(dòng)退出,設(shè)置方式為thread.setDaemon(True),要在thread.start()之前設(shè)置,默認(rèn)是false的,也就是主線程結(jié)束時(shí),子線程依然在執(zhí)行。
5.1 如下代碼,主線程已經(jīng)exit() 【其實(shí)并沒有真正結(jié)束】,子線程還在繼續(xù)執(zhí)行
import threading import timedef test():for i in range(10):print("test is run:", i)time.sleep(1)if __name__ == '__main__':# 創(chuàng)建子線程t1 = threading.Thread(target=test)# 啟動(dòng)子線程t1.start()# 休眠2秒time.sleep(2)print("我 OVER 了")# 退出exit()
5.2 設(shè)置守護(hù)線程
設(shè)置為守護(hù)線程(如果主線程結(jié)束了,也隨之結(jié)束)
線程.setDaemon(True)
總結(jié)
以上是生活随笔為你收集整理的python中的线程threading.Thread()使用的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Python进程multiprocess
- 下一篇: Python OS和shutil模块的常