如何在5分钟超时后终止被Python-SocketIO阻塞的线程？

我来帮你搞定这个问题——你遇到的核心痛点是：sys.exit()只会终止调用它的定时器线程本身，根本碰不到那个被SocketIO无限等待阻塞的工作线程。下面给你两个可行的解决方案，优先推荐第一种优雅的方式：

方案1：用线程事件通知工作线程主动退出（推荐） #

Python不建议强制终止线程，最好的方式是让工作线程自己检测退出信号并主动结束。我们可以用threading.Event来传递终止信号，同时修改SocketIO的阻塞逻辑，让它定期检查这个信号：

修改你的代码： #

import threading

class LiveMatches(commands.Cog):
    def __init__(self, client):
        self.client = client
        # 用字典存储每个线程对应的终止事件（按id区分）
        self.shutdown_events = {}

    def connect_to_scorebot(self, id, shutdown_event):
        feed = MatchFeed(self.client)
        feed.main(id, shutdown_event)  # 把终止事件传给feed的main方法

    def trigger_shutdown(self, id):
        # 获取对应线程的终止事件并触发
        shutdown_event = self.shutdown_events.pop(id, None)
        if shutdown_event:
            shutdown_event.set()

    def create_thread(self, id):
        shutdown_event = threading.Event()
        self.shutdown_events[id] = shutdown_event
        
        # 创建线程时传入终止事件
        new_thread = threading.Thread(target=self.connect_to_scorebot, args=(id, shutdown_event))
        new_thread.start()
        
        # 启动5分钟（300秒）后的定时器，触发终止
        threading.Timer(300, self.trigger_shutdown, args=(id,)).start()

修改MatchFeed的main方法： #

让它不再无限阻塞，而是循环检查终止事件，同时让SocketIO正常处理消息：

import socketio

class MatchFeed:
    def __init__(self, client):
        self.client = client

    def main(self, id, shutdown_event):
        sio = socketio.Client()

        # 定义消息处理逻辑
        @sio.on('score_update')
        def handle_score(data):
            # 处理比分更新的业务逻辑
            pass

        # 连接到Scorebot
        sio.connect("你的Scorebot地址")

        # 循环检查终止信号，同时让SocketIO处理消息
        while not shutdown_event.is_set():
            sio.sleep(1)  # 让出CPU，同时SocketIO会处理后台消息

        # 收到终止信号后，主动断开连接并退出
        sio.disconnect()

这个方案的好处是：线程会优雅地关闭Socket连接、释放资源，完全符合Python的线程设计规范。

方案2：用多进程替代多线程（备选） #

如果没办法修改MatchFeed.main的代码，或者SocketIO的阻塞逻辑无法调整，可以考虑用multiprocessing.Process代替threading.Thread——进程可以被强制终止：

from multiprocessing import Process
import threading

class LiveMatches(commands.Cog):
    def __init__(self, client):
        self.client = client
        self.processes = {}  # 存储每个id对应的进程

    def connect_to_scorebot(self, id):
        feed = MatchFeed(self.client)
        feed.main(id)

    def create_thread(self, id):
        new_process = Process(target=self.connect_to_scorebot, args=(id,))
        new_process.start()
        self.processes[id] = new_process
        
        # 5分钟后强制终止进程
        threading.Timer(300, lambda: self.processes.pop(id, None).terminate()).start()

⚠️ 注意：强制终止进程可能会导致资源泄漏（比如未正常关闭的Socket连接），而且如果self.client涉及进程间共享状态，需要额外处理（比如用Manager），所以这个方案只作为无法修改MatchFeed时的备选。

为什么你的原方法没用？ #

sys.exit()本质是在当前线程抛出SystemExit异常，这个异常只会终止调用它的线程（也就是你创建的定时器线程），对那个被SocketIO阻塞的工作线程完全没有影响——因为两个线程是独立的执行上下文。

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