第python子線程如何有序執(zhí)行一、前情提要

最近在寫一個(gè)項(xiàng)目，需要用到子線程，但是我們小學(xué)二年級(jí)就學(xué)過操作系統(tǒng)，線程的執(zhí)行是由系統(tǒng)的CPU調(diào)度算法所決定的，調(diào)度算法按照一系列的要求來從就緒隊(duì)列中選擇合適的線程分配CPU資源。

二、場景重現(xiàn)

好了，換句話說，線程的執(zhí)行順序是不確定的。來個(gè)python代碼我們看一下：

importthreading

deffun():

'''執(zhí)行函數(shù)'''

print(threading.current_thread().getName()+'正在執(zhí)行！')

#線程隊(duì)列

ths=[]

foriinrange(10):

ths.append(threading.Thread(target=fun))

#依次啟動(dòng)線程

forthinths:

th.start()

看一下效果：

不難看出，雖然第一次運(yùn)行的結(jié)果時(shí)有序執(zhí)行子線程，但是后續(xù)重復(fù)運(yùn)行程序的結(jié)果，顯然是順序不確定的，這就正好體現(xiàn)了線程的隨機(jī)性。

那么我們在某種特殊的場景下，我們需要讓子線程按照順序有序執(zhí)行，那改怎么做呢？

三、解決方案（一）

通過查詢threadingAPI我們可以發(fā)現(xiàn)一個(gè)這樣的函數(shù)：

Thread.join(timeout=None)

該方法的作用是等待當(dāng)前執(zhí)行線程終止

也就是說，哦那我調(diào)用start()方法開始線程之后，再調(diào)用這個(gè)方法不就行了嗎？答案是肯定的

importthreading

deffun():

'''執(zhí)行函數(shù)'''

print(threading.current_thread().getName()+'正在執(zhí)行！')

#線程隊(duì)列

ths=[]

foriinrange(10):

ths.append(threading.Thread(target=fun))

#依次啟動(dòng)線程

forthinths:

th.start()

th.join()

看一下效果：

這時(shí)候我們發(fā)現(xiàn)，不管如何運(yùn)行子線程的執(zhí)行順序都是有序的

四、解決方案（二）

就這一種方法嗎？當(dāng)然不是的，而且上面那種方法，如果是控制臺(tái)界面是沒有問題的，但是如果是GUI界面，那就由大問題了。

那么我們再想想join()方法，還可以換種方法用嗎？

我們可以用一個(gè)小技巧，可以將上一個(gè)線程傳入target，

在函數(shù)中判斷，如果上一個(gè)線程還在執(zhí)行，那么就調(diào)用join()方法等待其執(zhí)行，等待執(zhí)行完畢后，再讓當(dāng)前線程執(zhí)行。

代碼：

importthreading

deffun(preThread):

'''執(zhí)行函數(shù)'''

#等待上一個(gè)線程執(zhí)行完畢

ifpreThread!=None:

preThread.join()

#執(zhí)行當(dāng)前線程

print(threading.current_thread().getName()+'正在執(zhí)行！')

#線程隊(duì)列

ths=[]

foriinrange(10):

ifi==0:

ths.append(threading.Thread(target=fun,args=(None,)))

else:

ths.append(threading.Thread(target=fun,args=(ths[-1],)))

#依次啟動(dòng)線程

forthinths:

th.st