Python多線程threading join和守護(hù)線程setDeamon原理詳解
同一進(jìn)程下的多個(gè)線程共享內(nèi)存數(shù)據(jù),多個(gè)線程之間沒有主次關(guān)系,相互之間可以操作;cpu執(zhí)行的都是線程,默認(rèn)程序會(huì)開一個(gè)主線程;進(jìn)程是程序以及和程序相關(guān)資源的集合;某些場(chǎng)景下我們可以使用多線程來達(dá)到提高程序執(zhí)行效率的目的,下面就多線程的一些基礎(chǔ)知識(shí)做簡要說明
簡單的多線程
import threading, time def test1(x): time.sleep(5) print(x**x) #下面定義兩個(gè)線程調(diào)用test1這個(gè)函數(shù),創(chuàng)建多線程使用如下語法,target后面跟函數(shù)名,args傳遞實(shí)參,實(shí)參需要以元組形式傳遞 start_time = time.time() t1 = threading.Thread(target=test1, args=(5,)) t2 = threading.Thread(target=test1, args=(6,)) #啟動(dòng)多線程 t1.start() t2.start() end_time = time.time() total_time = end_time - start_time print("two Thread used %s time"%total_time) #由于使用多線程,t1 t2啟動(dòng)以后并不會(huì)等待期執(zhí)行完程序才繼續(xù)往后走,因?yàn)橹鞒绦蚓褪侵骶€程和t1 t2是并行執(zhí)行的,主程序執(zhí)行到此t1 t2并未運(yùn)行完成 time.sleep(6) #多線程啟動(dòng)數(shù)量比較多時(shí)可以使用for循環(huán),多線程并行執(zhí)行,打印的結(jié)果有可能不是按照啟動(dòng)順序來打印的 for i in range(5): t3 = threading.Thread(target=test1, args=(i,)) t3.start() time.sleep(6)
主線程等待非主線程執(zhí)行完畢才繼續(xù)執(zhí)行 join方法
#有些情況主線程需要子線程執(zhí)行完畢后,有可能是將數(shù)據(jù)處理完畢后才執(zhí)行接下來的主線程的東西 start_time1 = time.time() tl = [] #將多線程的對(duì)象存起來,用于后面join方法 for i in range(5): t4 = threading.Thread(target=test1, args=(i,)) t4.start() tl.append(t4) for t in tl: #將多線程并發(fā)join,參加join的子線程執(zhí)行完畢后才繼續(xù)執(zhí)行下面的主線程。 t.join() end_time1 = time.time() total_time1 = end_time1 - start_time1 print(total_time1) #此次執(zhí)行時(shí)間大約就是5s
#如果多個(gè)子線程一些join一些沒有join主線程怎么處理???部分子線程join主線程會(huì)等join時(shí)間最長的子線程結(jié)束后才繼續(xù),未參與join的子線程仍然和主線程并行運(yùn)行 t5 = threading.Thread(target=test1, args=(5,)) t6 = threading.Thread(target=test1, args=(6,)) t5.start() t6.start() t5_join_start_time = time.time() t5.join() time.sleep(10) t5_join_end_time = time.time() print("t5 join time is %s"%(t5_join_end_time - t5_join_start_time)) #實(shí)際耗時(shí)15s
守護(hù)線程 setDeamon
#守護(hù)進(jìn)程,即主線程結(jié)束以后所有的其它線程也立即結(jié)束,不用等其它線程執(zhí)行完畢;正常情況即使沒加join主線程執(zhí)行完畢當(dāng)其它線程未執(zhí)行完畢程序也不會(huì)退出,必須等待所有線程執(zhí)行完畢程序才結(jié)束,類似主程序在末尾有默認(rèn)的join def test1(x): time.sleep(5) print("i an other Thread",x**x) for i in range(5): t = threading.Thread(target=test1, args=(i,)) t.setDaemon(True) t.start() print("Main Thread is done") #整個(gè)程序結(jié)束,不會(huì)等待守護(hù)線程打印操作執(zhí)行完畢就直接結(jié)束了
遞歸鎖 Rlock
#遞歸鎖,一個(gè)鎖里面嵌套著鎖,如果不使用遞歸鎖會(huì)導(dǎo)致釋放鎖邏輯錯(cuò)誤,整個(gè)程序就跑偏了;使用遞歸鎖后程序會(huì)維護(hù)一個(gè)加鎖 解鎖的數(shù)據(jù)結(jié)構(gòu),保證釋放鎖不會(huì)出問題 lock = threading.Lock() def test2(): lock.acquire() print("this is test2") lock.release() def test3(): lock.acquire() print("this is test3") lock.release() def test4(): lock.acquire() test2() print("this is test4") test3() lock.release() rlock_test = threading.Thread(target=test4) rlock_test.start() while threading.active_count() != 1: print("current thread count is",threading.active_count()) #整個(gè)程序一直在打印有兩個(gè)線程,非主線程的鎖嵌套出問題導(dǎo)致無法退出,整個(gè)程序卡死 time.sleep(1)
將lock = threading.Lock()修改為lock = threading.RLock()整個(gè)程序就能正常結(jié)束;正常結(jié)束的輸出如下
this is test2
this is test4
current thread count is 2
this is test3
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Python實(shí)現(xiàn)FTP文件傳輸?shù)膶?shí)例
在本篇文章里小編給各位分享的是關(guān)于Python實(shí)現(xiàn)FTP文件傳輸?shù)膶?shí)例以及相關(guān)代碼,需要的朋友們學(xué)習(xí)下。2019-07-07Django中反向生成models.py的實(shí)例講解
今天小編就為大家分享一篇Django中反向生成models.py的實(shí)例講解,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-05-05在Python中執(zhí)行系統(tǒng)命令的方法示例詳解
最近在做那個(gè)測(cè)試框架的時(shí)候發(fā)現(xiàn)對(duì)python執(zhí)行系統(tǒng)命令不太熟悉,所以想著總結(jié)下,下面這篇文章主要給大家介紹了關(guān)于在Python中執(zhí)行系統(tǒng)命令的方法,需要的朋友可以參考借鑒,下面來一起看看吧。2017-09-09Pyspark獲取并處理RDD數(shù)據(jù)代碼實(shí)例
這篇文章主要介紹了Pyspark獲取并處理RDD數(shù)據(jù)代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03Python實(shí)現(xiàn)語音識(shí)別vosk的示例代碼
Vosk是一個(gè)功能強(qiáng)大且易于使用的語音識(shí)別工具包,它提供了Python綁定,使得在Python中使用Vosk變得非常方便,本文主要介紹了Python實(shí)現(xiàn)語音識(shí)別vosk的示例代碼,具有一定的參考價(jià)值,感興趣的可以了解一下2023-12-12