多線程編程中的join函數


# 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"

 

Join的作用是眾所周知的,阻塞進程直到線程執行完畢

 

這個小程序使用了兩個線程thread1和thread2,線程執行的動作分別是doWaiting()和doWaiting1(),函數體就是打印「開始」+休眠3秒+打印「結束」,分別附加上時間用來查看程序執行的過程。后面用start()方法同步開始執行兩個線程。然后開始循環調用兩個線程的join()方法,在此之前和之后都會用print函數做好開始結束的標記。我們主要觀察for tt in tsk: tt.join()。

join()不帶參數的情況下,執行如下:

start waiting1: 22:54:09

start waiting2: 22:54:09

start join: 22:54:09

stop waiting1: 22:54:12

stop waiting2: 22:54:17

end join: 22:54:17


Process finished with exit code 0

 

可以看到,兩個線程並行執行,進程1在3s后結束,進程2在8s后結束,然后回到主進程,執行打印「end join」。

下面把參數設置成超時2s,即tt.join(2),執行如下:

start waiting1: 22:54:57

start waiting2: 22:54:57

start join: 22:54:57

stop waiting1: 22:55:00

end join: 22:55:01

stop waiting2: 22:55:05


Process finished with exit code 0

兩個線程開始並發執行,然后執行線程1的join(2),等線程1執行2s后就不管它了,執行線程2的join(2),等線程2執行2s后也不管它了(在此過程中線程1執行結束,打印線程1的結束信息),開始執行主進程,打印「end join」。4s之后線程2執行結束。

總結一下:

1.join方法的作用是阻塞主進程(擋住,無法執行join以后的語句),專注執行多線程。

2.多線程多join的情況下,依次執行各線程的join方法,前頭一個結束了才能執行后面一個。

3.無參數,則等待到該線程結束,才開始執行下一個線程的join。

4.設置參數后,則等待該線程這么長時間就不管它了(而該線程並沒有結束)。不管的意思就是可以執行后面的主進程了。

最后附上參數為2時的程序執行流程表,自己畫的orz,這樣看起來更好理解。


注意!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系我们删除。



 
粤ICP备14056181号  © 2014-2021 ITdaan.com