如何终止Python另一线程中的while True循环 支持asyncio等框架方案

原代码不生效的根本原因 #

你给出的示例代码存在3个核心错误导致终止逻辑完全失效：

• 传递target参数时写了check_sth()，加括号会直接在主线程同步执行该函数，根本没有创建新线程，后续代码永远不会运行
• 最后把终止标志condition赋值为False，和你判断退出的条件完全相反，就算线程正常运行也永远不会触发退出逻辑
• 空参数的args=(,)属于语法错误，无参数时不需要传args参数，或者传空元组()

标准线程方案：用threading.Event实现安全终止 #

Python标准库的threading.Thread没有官方提供的kill()方法，因为强行终止线程会导致不可控的资源泄漏（比如锁未释放、打开的文件/网络连接未关闭），推荐用事件对象替代全局变量做终止标志，比全局变量更线程安全：

from time import sleep
from threading import Thread, Event

def check_sth(stop_event: Event):
    while not stop_event.is_set():
        sleep(0.25)
        do_sth() # 执行你的业务逻辑
    print("Condition met, ending")

# 初始化终止事件
stop_event = Event()
# 注意target传函数对象，不要加括号
thread = Thread(target=check_sth, args=(stop_event,))
thread.start()

# 2秒后触发终止
sleep(2)
stop_event.set()
# 等待线程正常退出
thread.join()

非标准强行杀线程方案（不推荐生产环境使用） #

如果一定要实现类似kill()的逻辑，可以通过ctypes调用Python解释器底层API给目标线程抛出异常，风险较高仅做参考：

import ctypes
from threading import Thread

def async_raise(tid, exctype):
    tid = ctypes.c_long(tid)
    if not ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, ctypes.py_object(exctype)):
        raise ValueError("Invalid thread ID")

def kill_thread(thread: Thread):
    async_raise(thread.ident, SystemExit)

# 调用示例
# thread = Thread(target=xxx)
# thread.start()
# kill_thread(thread)

asyncio协程方案（推荐IO密集型场景使用） #

asyncio的任务原生支持取消，是更安全简单的方案，不需要自己维护终止标志：

import asyncio

async def check_sth():
    try:
        while True:
            await asyncio.sleep(0.25)
            # 若do_sth是同步阻塞逻辑，需要用asyncio.to_thread包裹避免阻塞事件循环
            do_sth()
    except asyncio.CancelledError:
        print("Condition met, ending")
        raise # 可选配置：是否向上传递取消异常

async def main():
    task = asyncio.create_task(check_sth())
    # 2秒后取消任务
    await asyncio.sleep(2)
    task.cancel()
    # 等待任务处理取消逻辑
    try:
        await task
    except asyncio.CancelledError:
        pass

asyncio.run(main())

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