使用threading.Thread.join()等待线程结束的方法

在Python中，可以使用threading.Thread.join()方法来等待线程的结束。join()方法会导致当前线程处于阻塞状态，直到目标线程结束才会解除阻塞，然后继续执行。

以下是一个简单的使用join()方法的示例：

import threading
import time

def worker():
    print("Worker thread started")
    time.sleep(2)  # 模拟线程执行任务的耗时
    print("Worker thread finished")

print("Main thread started")

# 创建一个新的线程
thread = threading.Thread(target=worker)

# 启动线程
thread.start()

# 等待线程结束
thread.join()

print("Main thread finished")

在上面的例子中，我们首先创建了一个新的线程，并指定了它要执行的函数worker()。然后，我们启动了该线程，并在主线程中调用join()方法等待该线程的结束。

在worker()函数中，我们分别打印了"Worker thread started"和"Worker thread finished"。注意，在调用time.sleep(2)时，我们模拟了线程执行任务的耗时。

执行上述代码后，你将会看到以下输出：

Main thread started
Worker thread started
Worker thread finished
Main thread finished

从输出结果中，我们可以看出主线程和工作线程按照预期的顺序执行。主线程首先被启动，然后创建的工作线程启动，并打印了"Worker thread started"。工作线程继续执行，打印了"Worker thread finished"，然后主线程才继续执行，打印了"Main thread finished"。

通过使用join()方法，主线程可以等待工作线程的结束，以便在需要工作线程的结果或执行特定操作之前等待其完成。

除了简单的等待外，join()方法还可以接收一个可选的超时参数，用于设置等待线程结束的最长时间。如果到达超时时间仍然没有结束，join()方法会解除阻塞，并允许主线程继续执行。下面是一个带有超时参数的示例：

import threading
import time

def worker():
    print("Worker thread started")
    time.sleep(5)  # 模拟线程执行任务的耗时
    print("Worker thread finished")

print("Main thread started")

# 创建一个新的线程
thread = threading.Thread(target=worker)

# 启动线程
thread.start()

# 等待线程结束，设置最长等待时间为3秒
thread.join(3)

if thread.is_alive():
    print("Thread didn't finish within 3 seconds")
else:
    print("Thread finished")

print("Main thread finished")

在这个例子中，我们的工作线程的执行时间为5秒，而我们在join()方法中设置的超时时间为3秒。因此，当线程还未结束时，超时时间就已经到达。

在这种情况下，join()方法会返回，主线程会继续执行。我们通过使用thread.is_alive()方法来检查工作线程是否仍然在执行。在这个例子中，工作线程没有在超时时间内结束，因此会打印"Thread didn't finish within 3 seconds"。