Python threading模块线程信号实现求助：线程1触发线程2启动并同步终止

当然有可行的实现方式！我们可以结合Python threading模块里的**Event同步事件和线程的join()方法**来完美满足你的需求：前者用来让线程1给线程2发送启动信号，后者用来保证线程2必须等线程1终止后才会结束。

核心思路 #

• 启动信号传递：用threading.Event创建一个信号标记，线程2启动后先阻塞等待这个标记被触发；线程1完成初始化或指定步骤后，通过set()方法触发这个信号，线程2随即开始执行任务。
• 终止等待：线程2在自身任务执行过程中（或完成后），调用线程1对象的join()方法，这会让线程2暂停执行，直到线程1完全终止后，线程2才会继续执行并最终结束。

完整代码示例 #

import threading
import time

def thread1_task(start_signal, thread2):
    print("线程1：开始执行初始化工作...")
    time.sleep(2)  # 模拟耗时的初始化操作
    print("线程1：初始化完成，发送启动信号给线程2")
    start_signal.set()  # 触发启动信号，唤醒线程2
    
    print("线程1：继续执行后续业务任务...")
    time.sleep(3)  # 模拟线程1的剩余工作
    print("线程1：所有任务完成，即将终止")

def thread2_task(start_signal, thread1):
    print("线程2：已启动，等待线程1的启动信号...")
    start_signal.wait()  # 阻塞，直到收到启动信号
    print("线程2：收到启动信号，开始执行自身任务...")
    
    time.sleep(4)  # 模拟线程2的业务处理
    print("线程2：自身任务完成，开始等待线程1终止...")
    thread1.join()  # 等待线程1完全终止
    print("线程2：线程1已终止，自身即将结束")

if __name__ == "__main__":
    # 创建用于传递启动信号的Event对象
    start_event = threading.Event()
    
    # 先创建线程1（线程2需要引用它来调用join）
    thread1 = threading.Thread(target=thread1_task, args=(start_event, None))
    # 创建线程2，传入启动信号和线程1的引用
    thread2 = threading.Thread(target=thread2_task, args=(start_event, thread1))
    
    # 先启动线程2，让它进入等待状态
    thread2.start()
    # 再启动线程1
    thread1.start()
    
    # 主线程等待两个子线程全部结束
    thread1.join()
    thread2.join()
    print("所有线程执行完毕")

关键细节解释 #

1. 线程启动顺序：必须先启动线程2，让它先进入wait()阻塞状态；如果先启动线程1，可能线程1已经触发了信号，线程2再启动时会直接跳过等待，不符合需求。
2. Event的线程安全性：Event是Python线程库提供的线程安全同步工具，不用担心多线程下的信号触发问题。
3. join()的作用：thread1.join()会让调用它的线程（这里是线程2）暂停，直到thread1的任务完全执行完毕、线程状态变为终止后，才会继续执行后续代码。

内容的提问来源于stack exchange，提问作者Tej