如何终止Python中运行的函数？异步任务终止同步代码失效问题

你的代码失效的核心原因是asyncio的事件循环是协作式的：loop()函数里的while True: pass是纯同步死循环，会一直占用事件循环线程，完全不给其他任务（比如asyncio.sleep(3)）执行的机会，自然也无法触发后续的task.cancel()。

下面给出几种可行的解决方案：

方案1：让同步代码主动让出控制权 #

如果你的同步逻辑可以拆分为小块，在循环中插入await asyncio.sleep(0)，强制让出事件循环的控制权，这样其他任务就能正常执行：

import asyncio

async def loop():
    while True:
        # 这里替换为你的同步业务代码
        # 每执行一轮就让出控制权给事件循环
        await asyncio.sleep(0)

async def main():
    task = asyncio.create_task(loop())
    await asyncio.sleep(3)
    print('1223')
    task.cancel()
    # 必须等待任务处理CancelledError，否则会抛出未处理异常
    try:
        await task
    except asyncio.CancelledError:
        print('loop任务已被取消')
    print('x')

asyncio.run(main())

方案2：用线程隔离同步阻塞代码 #

如果你的同步代码是无法拆分的密集型阻塞操作，把它放到独立线程中运行，避免阻塞asyncio事件循环：

import asyncio
from threading import Thread

# 全局终止标志，控制线程退出
stop_flag = False

def sync_loop():
    while not stop_flag:
        # 这里替换为你的纯同步阻塞代码
        pass

async def main():
    thread = Thread(target=sync_loop, daemon=True)
    thread.start()
    
    await asyncio.sleep(3)
    print('1223')
    # 设置终止标志，让线程自行退出
    global stop_flag
    stop_flag = True
    # 等待线程退出，超时则放弃（守护线程会随程序结束自动终止）
    thread.join(timeout=1)
    print('x')

asyncio.run(main())

注意：如果同步代码是完全无法响应终止标志的死循环，只能依赖守护线程在程序结束时自动终止，无法中途安全强制终止线程（强制终止线程可能导致资源泄漏）。

方案3：用线程池执行同步任务 #

利用asyncio.run_in_executor将同步任务放到线程池，通过future.cancel()标记任务取消（但无法强制终止正在运行的线程，仅停止等待结果）：

import asyncio
import concurrent.futures

def sync_loop():
    while True:
        # 这里替换为你的纯同步阻塞代码
        pass

async def main():
    executor = concurrent.futures.ThreadPoolExecutor()
    # 将同步任务提交到线程池
    future = asyncio.get_event_loop().run_in_executor(executor, sync_loop)
    
    await asyncio.sleep(3)
    print('1223')
    # 标记任务取消，不再等待结果
    future.cancel()
    # 立即关闭线程池，不等待未完成任务
    executor.shutdown(wait=False)
    print('x')

asyncio.run(main())

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