Python 多執行緒 thread join() 的作用
阿新 • • 發佈:2018-10-31
原文地址
在 Python 的多執行緒程式設計中,在例項程式碼中經常有 thread1.join()這樣的程式碼。那麼今天咱們用實際程式碼來解釋一下 join 函式的作用。
join的原理就是依次檢驗執行緒池中的執行緒是否結束,沒有結束就阻塞直到執行緒結束,如果結束則跳轉執行下一個執行緒的join函式。
先看看這個:
1. 阻塞主程序,專注於執行多執行緒中的程式。
2. 多執行緒多join的情況下,依次執行各執行緒的join方法,前頭一個結束了才能執行後面一個。
3. 無引數,則等待到該執行緒結束,才開始執行下一個執行緒的join。
4. 引數timeout為執行緒的阻塞時間,如 timeout=2 就是罩著這個執行緒2s 以後,就不管他了,繼續執行下面的程式碼。
程式碼示例:
# coding: utf-8 # 測試多執行緒中join的功能 import threading, time def doWaiting(): print 'start waiting1: ' + time.strftime('%H:%M:%S') + "\n" time.sleep(3) print 'stop waiting1: ' + time.strftime('%H:%M:%S') + "\n" def doWaiting1(): print 'start waiting2:' + time.strftime('%H:%M:%S') + "\n" time.sleep(8) print 'stop waiting2: ', time.strftime('%H:%M:%S') + "\n" tsk = [] thread1 = threading.Thread(target = doWaiting) thread1.start() tsk.append(thread1) thread2 = threading.Thread(target = doWaiting1) thread2.start() tsk.append(thread2)print 'start join: ' + time.strftime('%H:%M:%S') + "\n" for tt in tsk: tt.join() print 'end join: ' + time.strftime('%H:%M:%S') + "\n"
CASE1:
按照程式碼示例中的程式碼執行。
執行結果:
start waiting1: 00:39:03 start waiting2: 00:39:03 start join: 00:39:03 stop waiting1: 00:39:06 stop waiting2: 00:39:11 end join: 00:39:11 [Finished in 8.0s]
執行結果分析:
1. 兩個執行緒在同一時間開啟,join 函式執行。
2. waiting1 執行緒執行(等待)了3s 以後,結束。
3. waiting2 執行緒執行(等待)了8s 以後,執行結束。
4. join 函式(返回到了主程序)執行結束。
CASE2:
將 join 的引數改成2 即 tt.join(2)
執行結果:
start waiting1: 00:45:32 start waiting2: 00:45:32 start join: 00:45:32 stop waiting1: 00:45:35 end join: 00:45:36 stop waiting2: 00:45:40 [Finished in 8.0s]
執行結果分析:
1. 兩個執行緒在同一時間開啟,join 函式執行。
2. wating1 執行緒在執行(等待)了三秒以後,完成。
3. join 退出(兩個2s,一共4s,36-32=4,無誤)。
4. waiting2 執行緒由於沒有在 join 規定的等待時間內(4s)完成,所以自己在後面執行完成。