本文實例講述了Python多線程threading模塊用法。分享給大家供大家參考,具體如下:
多線程 - threading
python的thread模塊是比較底層的模塊,python的threading模塊對thread做了一些包裝,可以更加方便的被使用。
1. 使用threading模塊
單線程執行
#coding=utf-8 import time def saySorry(): print('跑一圈') time.sleep(1) if __name__ == "__main__": for i in range(5): saySorry()
運行結果:
跑一圈
跑一圈
跑一圈
跑一圈
跑一圈
多線程執行
#coding=utf-8 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()
方法來啟動
2. 主線程會等待所有的子線程結束后才結束
#coding=utf-8 import threading from time import sleep,ctime,time def run(): for i in range(3): print('在跑步...%d'%i) sleep(1) def sing(): for i in range(3): print('在唱歌...%d'%i) sleep(1) if __name__ == "__main__": print('------start------' + ctime()) t1 = threading.Thread(target=run) t2 = threading.Thread(target=sing) t1.start()#啟動線程 t2.start() # sleep(5)# 屏蔽此行代碼,試試看,程序是否會立即結束? print('------stop------' + ctime())
運行結果:
------start------Thu Aug 24 13:38:28 2017
在跑步...0
------stop------Thu Aug 24 13:38:28 2017
在唱歌...0
在跑步...1
在唱歌...1
在跑步...2
在唱歌...2
3. 查看線程數量
#coding=utf-8 import threading from time import sleep,ctime,time def run(): for i in range(3): print('在跑步...%d'%i) sleep(1) def sing(): for i in range(3): print('在唱歌...%d'%i) sleep(1) if __name__ == "__main__": print('------start------' + ctime()) t1 = threading.Thread(target=run) t2 = threading.Thread(target=sing) t1.start()#啟動線程 t2.start() while True: length = len(threading.enumerate()) print('當前運行的線程數為:' , length , ctime()) if length <= 1: break # sleep(5)# 屏蔽此行代碼,試試看,程序是否會立即結束? print('------stop------' + ctime())
運行結果:
由于數量龐大,在此不展示。。。。。。
4.線程執行代碼的封裝 - threading.Thread子類
#coding=utf-8 import threading import time class MyThread(threading.Thread): def run(self): for i in range(3): time.sleep(1) msg = 'i am '+self.name+'@'+str(i) #name屬性中保存的是當前線程的名字 print(msg) if __name__ == "__main__": t = MyThread() t.start()
運行結果:
i am Thread-1@0
i am Thread-1@1
i am Thread-1@2
說明:
python的
threading.Thread
類有一個run方法,用于定義線程的功能函數,可以在自己的線程類中覆蓋該方法。在創建自己的線程實例后,通過Thread類的
start()
方法,可以啟動該線程,交給python虛擬機進行調度,當該線程獲得執行的機會時,就會調用run方法執行線程。
5.線程的執行順序
#coding=utf-8 import threading import time class MyThread(threading.Thread): def run(self): for i in range(3): time.sleep(1) msg = 'i am '+self.name+'@'+str(i) #name屬性中保存的是當前線程的名字 print(msg) def test(): for i in range(5): t = MyThread() t.start() if __name__ == "__main__": test()
運行結果:
i am Thread-1@0
i am Thread-2@0
i am Thread-3@0
i am Thread-4@0
i am Thread-5@0
i am Thread-1@1
i am Thread-2@1
i am Thread-3@1
i am Thread-4@1
i am Thread-5@1
i am Thread-1@2
i am Thread-2@2
i am Thread-3@2
i am Thread-4@2
i am Thread-5@2
說明:
(運行的結果可能不一樣,但是大體是一致的)
從代碼的執行結果我們可以看出,多線程程序的執行順序是不確定的。當執行到sleep語句時,線程將被阻塞(Blocked),到sleep結束后,線程進入就緒(Runnable)狀態,等待調度。而線程調度將自行選擇一個線程執行。上面的代碼中只能保證每個線程都運行完整個run函數,但是線程的啟動順序、
run函數中每次循環的執行順序都不能確定。
總結
1. 每個線程一定會有一個名字,盡管上面的例子中沒有指定線程對象的name,但是python會自動為線程指定一個名字。
2. 當線程的run()方法結束時該線程完成。
3. 無法控制線程調度程序,但可以通過別的方式來影響線程調度的方式。
4. 線程的幾種狀態
多線程-共享全局變量
#coding=utf-8 import threading import time g_num = 100 def work1(): global g_num for i in range(3): g_num+=1 print('work1 --- num = %d'%g_num) def work2(): global g_num print('work2 --- num = %d'%g_num) if __name__ == "__main__": print('---start------g_num = %d'%g_num) t1 = threading.Thread(target=work1) t1.start() # 延時一會,保證t1線程中的事情做完 time.sleep(1) t2 = threading.Thread(target=work2) t2.start()
運行結果:
---start------g_num = 100
work1 --- num = 103
work2 --- num = 103
更多關于Python相關內容感興趣的讀者可查看本站專題:《Python進程與線程操作技巧總結》、《Python數據結構與算法教程》、《Python函數使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經典教程》、《Python+MySQL數據庫程序設計入門教程》及《Python常見數據庫操作技巧匯總》
希望本文所述對大家Python程序設計有所幫助。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
