Python?中?threading.Thread.join()?的使用方法示例詳解

更新時間：2024年06月12日 11:45:09 作者：q56731523

threading.Thread.join()用于阻塞當前線程,直到調用它的線程對象執(zhí)行完成或者超時,在Python中,想要充分利用多線程的優(yōu)勢,就需要對threading模塊中的 Thread 類了解,這里有一個非常簡單的多線程程序,幫助理解 threading.Thread.join 方法,感興趣的朋友跟隨小編一起看看吧

threading.Thread.join() 方法用于阻塞當前線程，直到調用它的線程對象執(zhí)行完成或者超時。這在需要等待子線程執(zhí)行完畢后再繼續(xù)執(zhí)行主線程時非常有用?；谒@種特性，我講用我的方法幫你選擇你合適的解決方案。

問題背景

在 Python 中，想要充分利用多線程的優(yōu)勢，就需要對 threading 模塊中的 Thread 類有一定的了解。這里有一個非常簡單的多線程程序，用于幫助我們理解 threading.Thread.join 方法。

import threading
val = 0
def increment():
    global val
    print("Inside increment")
    for x in range(100):
        val += 1
        print("val is now {} ".format(val))
thread1 = threading.Thread(target=increment, args=())
thread2 = threading.Thread(target=increment, args=())
thread1.start()
# thread1.join()
thread2.start()
# thread2.join()

這里有兩個問題：

如果注釋掉 thread1.join() 和 thread2.join()，那么輸出結果會是怎樣的？如果不注釋掉 thread1.join() 和 thread2.join()，那么輸出結果又會是怎樣的？

解決方法

1. 不注釋掉 join() 方法

如果我們不注釋掉 thread1.join() 和 thread2.join()，那么輸出結果如下：

Inside increment
val is now 1
val is now 2
val is now 3
...
val is now 100
Inside increment
val is now 1
val is now 2
val is now 3
...
val is now 100

2. 注釋掉 join() 方法

如果我們注釋掉 thread1.join() 和 thread2.join()，那么輸出結果如下：

Inside increment
Inside increment
val is now 1
val is now 1
val is now 2
val is now 3
...
val is now 99
val is now 2
val is now 3
...
val is now 98
val is now 99
val is now 100

比較輸出結果

通過比較這兩個輸出結果，我們可以發(fā)現，如果注釋掉 join() 方法，那么兩個線程的輸出結果是交織在一起的，這表明這兩個線程是并發(fā)執(zhí)行的。而如果不注釋掉 join() 方法，那么兩個線程的輸出結果是按照順序輸出的，這表明這兩個線程是串行執(zhí)行的。

join() 方法的作用

join() 方法的作用是讓調用它的線程等待另一個線程終止。在我們的例子中，thread1.join() 和 thread2.join() 的作用是讓主線程等待 thread1 和 thread2 兩個線程終止。如果不注釋掉這兩個方法，那么主線程就會等待這兩個線程終止后才繼續(xù)執(zhí)行。而如果注釋掉這兩個方法，那么主線程就不會等待這兩個線程終止，而是直接繼續(xù)執(zhí)行。

代碼示例：

為了更清楚地了解 join() 方法的作用，我們修改一下上面的代碼：

import threading
val = 0
def increment(msg,sleep_time):
    global val
    print("Inside increment")
    for x in range(10):
        val += 1
        print("%s : %d\n" % (msg,val))
        time.sleep(sleep_time)
thread1 = threading.Thread(target=increment, args=("thread_01",0.5))
thread2 = threading.Thread(target=increment, args=("thread_02",1))
thread1.start()
thread1.join()
thread2.start()
thread2.join()

如果我們運行這段代碼，那么輸出結果如下：

Inside increment
thread_01 : 1

thread_01 : 2

thread_01 : 3

thread_01 : 4

thread_01 : 5

thread_01 : 6

thread_01 : 7

thread_01 : 8

thread_01 : 9

thread_01 : 10

Inside increment
thread_02 : 1

thread_02 : 2

thread_02 : 3

thread_02 : 4

thread_02 : 5

thread_02 : 6

thread_02 : 7

thread_02 : 8

thread_02 : 9

thread_02 : 10