在Python多线程中，`join`机制用于控制线程的执行顺序，其核心作用是阻塞当前线程，直到调用`join`方法的线程执行完毕。 ### 机制原理 当在一个线程对象上调用`join`方法时，当前线程会被阻塞，程序会等待该线程执行完成后才会继续执行后续代码。如果不使用`join`，主线程和子线程会并发执行，主线程不会等待子线程完成就可能会直接退出。例如在默认情况下，主线程执行完自己的任务以后就会退出，此时子线程会继续执行自己的任务，直到任务结束 [^5]。 ### 作用 - **控制线程执行顺序**：在需要严格控制线程执行顺序的场景下，`join`非常有用。如果两个线程任务之间存在依赖关系，就需要显示地使用`join`来确保线程按顺序执行。若两个线程任务之间没有关系，不需要考虑先后顺序时，则可以不用`join` [^1]。 - **确保子线程执行完毕**：通过`join`可以保证所有子线程都执行完成后，主线程才退出。可以将所有线程放入一个列表，通过循环对列表中的所有线程使用`join`方法，以此保证全部子线程都能运行完成，主线程才退出 [^4]。 ### 示例代码 以下是有`join`和没有`join`的示例代码： #### 有`join`的情况 ```python import threading import time def run(): time.sleep(2) print('当前线程的名字是： ', threading.current_thread().name) time.sleep(2) start_time = time.time() print('这是主线程：', threading.current_thread().name) thread_list = [] for i in range(5): t = threading.Thread(target=run) thread_list.append(t) for t in thread_list: t.setDaemon(True) t.start() for t in thread_list: t.join() print('主线程结束了！', threading.current_thread().name) print('一共用时：', time.time() - start_time) ``` 在这个示例中，主线程会等待所有子线程执行完毕后才会结束 [^2]。 #### 没有`join`的情况 ```python import threading import time def run(): time.sleep(2) print('当前线程的名字是： ', threading.current_thread().name) time.sleep(2) if __name__ == '__main__': start_time = time.time() print('这是主线程：', threading.current_thread().name) thread_list = [] for i in range(5): t = threading.Thread(target=run) thread_list.append(t) for t in thread_list: t.start() print('主线程结束！', threading.current_thread().name) print('一共用时：', time.time() - start_time) ``` 在这个示例中，主线程不会等待子线程执行完毕，会直接结束 [^3]。 ### `join`的`timeout`参数 `join`有一个`timeout`参数。当设置守护线程时，主线程对于子线程等待`timeout`的时间将会杀死该子线程，最后退出程序。如果有多个子线程，全部的等待时间就是每个`timeout`的累加和。没有设置守护线程时，主线程将会等待`timeout`的累加和这样的一段时间，时间一到，主线程结束，但是并没有杀死子线程，子线程依然可以继续执行，直到子线程全部结束，程序才退出 [^3]。