即使忽略了CancelledError，如何取消任务执行？

Question

这是取消任务的示例：

import asyncio


async def some_func():
    await asyncio.sleep(2)
    print('Haha! Task keeps running!')
    await asyncio.sleep(2)

async def cancel(task):
    await asyncio.sleep(1)
    task.cancel()

async def main():
    func_task = asyncio.ensure_future(some_func())
    cancel_task = asyncio.ensure_future(cancel(func_task))
    try:
        await func_task
    except asyncio.CancelledError:
        print('Task cancelled as expected')

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

# Task cancelled as expected
# [Finished in 1.2s]

它工作正常，任务被取消。如果CancelledError被捕获到内部some_func任务不会被取消：

async def some_func():
    try:
        await asyncio.sleep(2)
    except:
        pass
    print('Haha! Task keeps running!')
    await asyncio.sleep(2)

# Haha! Task keeps running!
# [Finished in 3.2s]

很容易忘记我不应该在异步代码中的任何地方抑制异常（或者some_func可以是第三方代码，例如），但任务应该被取消。反正我能做到吗？或者忽略CancelledError意味着任务根本无法取消？

Answer 1

您无法取消抑制CancelledError. 这类似于无法关闭忽略GeneratorExit.

这是故意行为。任务可能想要在取消时做一些额外的工作（例如资源清理），因此捕获CancelledError可能是个好主意但抑制通常是编程错误的迹象。

如果您有不妥协的打算，Python 通常允许您射击自己的脚。

捕获所有异常甚至禁止通过按下关闭 python 进程，<Ctrl+C>因为它是在KeyboardInterrupt内部转换的。