这是取消任务的示例:

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意味着根本无法取消任务?

最佳答案

您无法取消隐藏CancelledError的任务。
这几乎无法关闭忽略GeneratorExit的生成器。

这是故意行为。 Task可能要在取消上做一些额外的工作(例如,资源清理),因此捕获CancelledError可能是个好主意,但抑制通常是编程错误的标志。

如果您坚定不移地打算这样做,Python通常会允许您自己射击。

捕获所有异常甚至禁止通过按键关闭python进程,因为它是在内部翻译为KeyboardInterrupt的。

关于python - 即使忽略了CancelledError,如何取消任务执行?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/33576175/

10-12 18:14
查看更多