Python中如何终止执行时长超15秒的重复线程？

这个问题的核心在于Python线程没有强制终止的API，所以我们得用协作式取消的思路来做超时控制——简单说就是让doSomething自己定期检查是否需要停止，而不是硬杀线程。下面是调整后的完整实现：

import threading
import time

class YourClass:
    def __init__(self):
        self.timerSeconds = 5  # 设定每5秒执行一次
        self.timeoutSeconds = 15  # 超时阈值15秒

    def repeatProcess(self):
        # 保留你原有的离线检查逻辑（示例中注释掉，实际按需启用）
        # if self.is_offline:
        #     return
        
        start_time = time.time()
        stop_event = threading.Event()
        worker_thread = None

        def worker():
            self.doSomething(stop_event)

        def timeout_handler():
            print("执行超时，触发终止信号")
            stop_event.set()
            # 给工作线程1秒时间退出，避免卡死
            if worker_thread.is_alive():
                worker_thread.join(timeout=1)

        # 启动工作线程执行任务
        worker_thread = threading.Thread(target=worker)
        worker_thread.start()

        # 启动超时监控定时器
        timeout_timer = threading.Timer(self.timeoutSeconds, timeout_handler)
        timeout_timer.start()

        # 等待工作线程完成
        worker_thread.join()
        # 任务正常结束，取消未触发的超时定时器
        if timeout_timer.is_alive():
            timeout_timer.cancel()

        execution_time = time.time() - start_time
        print(f"Execution time {execution_time:.2f} seconds")

        # 调度下一次执行
        next_timer = threading.Timer(self.timerSeconds, self.repeatProcess)
        next_timer.start()

    def doSomething(self, stop_event):
        print("开始执行doSomething")
        # 实际业务代码中，要在关键步骤插入终止检查
        # 这里模拟耗时操作作为示例
        for i in range(20):
            if stop_event.is_set():
                print("doSomething收到终止信号，提前退出")
                return
            time.sleep(1)
            print(f"doSomething执行中...第{i+1}秒")
        print("doSomething执行完成")

if __name__ == '__main__':
    obj = YourClass()
    # 启动周期性任务线程
    trackingThread = threading.Thread(name='repeatThread', target=obj.repeatProcess)
    trackingThread.daemon = True
    trackingThread.start()

    # 主线程保持运行，避免守护线程随主线程退出
    while True:
        time.sleep(1)

关键逻辑说明： #

1. 协作式终止：通过threading.Event传递终止信号，doSomething里需要定期调用stop_event.is_set()检查是否要退出。如果你的任务里有阻塞IO操作，建议用支持超时参数的API（比如requests.get(timeout=...)），或者把大任务拆分成小步骤插入检查点。
2. 超时监控：启动一个15秒的定时器，超时后触发终止信号，并等待工作线程退出。
3. 任务调度：不管任务是正常完成还是超时终止，都会在5秒后重新启动repeatProcess，保证大致每5秒执行一次的节奏。
4. 资源清理：任务正常结束时会取消未触发的超时定时器，避免不必要的资源浪费。

如果你的doSomething是完全无法中断的阻塞操作（比如某些C扩展调用），这种协作方式可能失效，这时可以考虑用multiprocessing进程代替线程——进程支持强制终止，但会带来额外的资源开销。

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