如何在Python中干净终止由其他线程创建的While True线程？

核心问题分析 #

你遇到的是线程无法自动回收的问题：虽然跳出了while True循环，但线程对象未被正确清理，加上join()会阻塞监听线程，导致活跃线程数持续上涨。Python的垃圾回收机制不会主动终止线程，它仅回收线程对象占用的内存，但线程本身若未正常退出，仍会处于活跃状态。

优雅终止线程的可行方案 #

1. 给线程设置退出标志 #

为每个客户端线程添加可外部访问的退出标志，检测到socket异常时设置标志，让线程自然退出循环，之后无需阻塞监听线程，可在后台异步处理join()。

示例代码：

import threading
import socket

class ClientHandler(threading.Thread):
    def __init__(self, conn):
        super().__init__()
        self.conn = conn
        self._stop_event = threading.Event()

    def stop(self):
        self._stop_event.set()
        # 关闭socket强制唤醒阻塞的recv
        self.conn.close()

    def run(self):
        self.conn.settimeout(10)  # 设置超时
        while not self._stop_event.is_set():
            try:
                data = self.conn.recv(1024)
                if not data:  # 客户端主动断开
                    break
                # 处理数据逻辑
                print(f"Received: {data.decode()}")
            except socket.timeout:
                continue
            except socket.error as e:
                print(f"Socket error: {e}")
                break
        # 清理资源
        self.conn.close()
        print(f"Client thread exited")

# 监听线程逻辑
def listener():
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind(('0.0.0.0', 8080))
    server_socket.listen(5)
    client_threads = []

    while True:
        try:
            conn, addr = server_socket.accept()
            print(f"New connection from {addr}")
            handler = ClientHandler(conn)
            handler.start()
            client_threads.append(handler)
            # 后台清理已退出的线程，无需阻塞
            client_threads = [t for t in client_threads if t.is_alive()]
        except Exception as e:
            print(f"Listener error: {e}")

if __name__ == "__main__":
    threading.Thread(target=listener, daemon=True).start()
    # 主线程保持运行
    input("Press Enter to exit...\n")

2. 使用守护线程（Daemon Thread） #

将客户端线程设置为守护线程，主线程退出时所有守护线程会自动终止。但注意：主线程运行期间，守护线程不会自动退出，仍需配合退出标志让线程正常结束循环。

修改ClientHandler的初始化：

def __init__(self, conn):
    super().__init__(daemon=True)
    self.conn = conn
    self._stop_event = threading.Event()

3. 定期清理已退出线程 #

在监听线程中，定期遍历所有客户端线程，对已结束的线程调用join()（此时join()不会阻塞，因为线程已退出），再从列表中移除，避免内存泄漏。

比如在listener的循环中添加：

# 每接受10个连接清理一次，或定时清理
if len(client_threads) % 10 == 0:
    dead_threads = []
    for t in client_threads:
        if not t.is_alive():
            t.join()
            dead_threads.append(t)
    for t in dead_threads:
        client_threads.remove(t)

关于垃圾回收的说明 #

Python的垃圾回收（GC）仅回收不再被引用的对象内存。如果线程对象还被client_threads列表引用，GC不会回收它；即使列表移除了引用，线程本身若卡在recv()阻塞等场景未正常退出，GC也无法终止线程。必须让线程正常执行完run()方法，GC才能彻底回收线程资源。

关键注意事项 #

• 绝对不要使用thread._stop()方法，这是不安全的强制终止，可能导致资源泄漏或数据损坏。
• 处理socket时设置超时或使用非阻塞IO，避免线程一直卡在recv()无法响应退出标志。
• 定期清理已退出的线程，保持活跃线程列表的整洁。

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