执行阻塞任务时KeyboardInterrupt未被捕获的问题排查
核心原因
这是因为两次Ctrl+C触发的异常属于不同的上下文层级,第二次的异常根本没进入任务内部的执行流:
第一次Ctrl+C的处理逻辑
当第一次按下Ctrl+C时,asyncio.run()会捕获触发的KeyboardInterrupt,然后主动取消所有运行中的任务——具体表现为向start_consuming任务抛出CancelledError。
此时start_consuming里的第一个await asyncio.Future()被打断,抛出的CancelledError被外层except捕获,随后进入内层try块,执行await asyncio.Future(),任务再次挂起。第二次Ctrl+C的异常走向
由于内层的asyncio.Future()永远不会完成,start_consuming任务无法结束,asyncio.run()会一直卡在等待任务终止的阶段。
这时第二次按下Ctrl+C,触发的KeyboardInterrupt会直接抛到进程的顶层上下文(也就是if __name__ == '__main__':代码块所在的层级),而不会进入start_consuming任务的执行流程。因此内层的except根本没有机会捕获这个异常,最终导致进程直接终止。
额外补充
任务内部的try-catch只能捕获任务执行流中抛出的异常,比如任务被取消时的CancelledError,或者任务内部代码主动抛出的异常。而第二次Ctrl+C的异常绕过了asyncio的任务调度机制,直接作用于进程本身,自然无法被任务内部的捕获逻辑处理。
内容的提问来源于stack exchange,提问作者asant-leitha

