Python 多線程 thread join() 的做用

在 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）完成，因此本身在後面執行完成。

 

 

 

 

參考鏈接：

http://www.jb51.net/article/54628.htm