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

在Python中，threading模块提供了一个Thread类，用于在程序中创建和管理线程。其中，join()方法是Thread类中一个非常重要的方法之一。

join()方法用于等待线程完成。在线程中调用join()方法后，该线程将会变为非活动状态，直到该线程执行完毕或者超时时间到达。

下面是一个使用join()方法的示例:

import threading

def worker():
    print("Worker thread is starting...")
    for i in range(10):
        print("Working...")
    print("Worker thread is done.")

# 创建线程
t = threading.Thread(target=worker)

# 启动线程
t.start()

# 等待线程执行完毕
t.join()

print("All done.")

在上面的示例中，我们首先定义了一个worker函数，它会在一个线程中执行一些任务。然后我们创建了一个Thread对象t，指定了worker函数作为线程的目标函数。

接着，我们调用t.start()方法启动线程。线程会在后台开始执行worker函数中的任务。

紧接着，我们调用t.join()方法，主线程会等待t线程执行完毕。如果t线程执行完毕，主线程会继续执行后面的代码。否则，主线程会一直等待，直到t线程执行完毕或者超时。

最后，我们打印"All done."，表示主线程执行完毕。

在上述示例中，即使worker函数中的任务执行时间较长，主线程仍然会等待t线程执行完毕。如果不使用join()方法，主线程会立即执行下面的代码，而不会等待t线程执行完毕。

除了不带参数的join()方法，Thread类还提供了一个带有timeout参数的join(timeout)方法。这个方法会等待线程执行完毕，但是最多等待timeout秒。如果超过timeout秒，join()方法会返回，不再等待线程执行完毕。

下面是使用带有超时参数的join()方法的示例：

import threading
import time

def worker():
    print("Worker thread is starting...")
    time.sleep(5)
    print("Worker thread is done.")

# 创建线程
t = threading.Thread(target=worker)

# 启动线程
t.start()

# 等待线程执行完毕，最多等待2秒
t.join(2)

print("All done.")

在上面的示例中，worker函数会休眠5秒钟。我们调用t.join(2)方法，主线程会等待t线程执行完毕，最多等待2秒钟。因为worker函数的执行时间超过2秒，所以即使主线程等待2秒钟，t线程仍然没有执行完毕。在超时时间到达后，join()方法会返回，主线程会继续执行后面的代码。

综上所述，join()方法在Python的threading模块中非常有用，可以用于等待线程执行完毕。它可以确保在多线程程序中正确的同步和协调线程的执行顺序，并且可以方便地控制线程的执行时间。