即使忽略了 CancelledError,如何取消任务执行?
How to cancel Task execution even if it ignored CancelledError?
这是取消任务的例子:
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
.
的生成器
这是故意的行为。任务可能想要在取消时做一些额外的工作(例如资源清理),因此捕获 CancelledError
可能是个好主意,但抑制通常是编程错误的标志。
Python如果你有不妥协的意图,通常允许你自己动手。
捕获所有异常甚至禁止通过按 <Ctrl+C>
关闭 python 进程,因为它在内部被转换为 KeyboardInterrupt
。
这里的真正问题是使用笼统的“except”子句,这几乎不是一个好主意,或者在某些人看来,绝对不是一个好主意。
与其单独使用“except:”,不如始终指定要捕获的异常或基本异常 class。请注意,从 Python 3.8 开始,CancelledError 是 BaseException 而不是 Exception 的子class,而您通常希望用“except:”捕获的所有异常都是子class异常(它本身是 BaseException 的子 class)。 exception hierarchy 上的文档显示了这种关系。
所以这样更好:
try:
... (your code here)
except Exception:
pass
这将捕获并默默地忽略所有正常异常(这在大多数实际代码中仍然是不可取的,但在某些代码中绝对有效),同时允许其他异常通过。请注意,CancelledError、SystemExit、KeyboardInterrupt 和其他几个仍然会通过。如果您不喜欢退出时引起的“噪音”,那么您应该(最有可能)在更高级别专门捕获它们。
如果你真的想吞下除了 CancelledError 之外的所有东西,那么你会这样做:
try:
... (your code here)
except asyncio.CancelledError:
raise # avoid swallowing this one exception
except BaseException:
pass # silently swallow everything else: usually not a good idea
这是取消任务的例子:
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
.
这是故意的行为。任务可能想要在取消时做一些额外的工作(例如资源清理),因此捕获 CancelledError
可能是个好主意,但抑制通常是编程错误的标志。
Python如果你有不妥协的意图,通常允许你自己动手。
捕获所有异常甚至禁止通过按 <Ctrl+C>
关闭 python 进程,因为它在内部被转换为 KeyboardInterrupt
。
这里的真正问题是使用笼统的“except”子句,这几乎不是一个好主意,或者在某些人看来,绝对不是一个好主意。
与其单独使用“except:”,不如始终指定要捕获的异常或基本异常 class。请注意,从 Python 3.8 开始,CancelledError 是 BaseException 而不是 Exception 的子class,而您通常希望用“except:”捕获的所有异常都是子class异常(它本身是 BaseException 的子 class)。 exception hierarchy 上的文档显示了这种关系。
所以这样更好:
try:
... (your code here)
except Exception:
pass
这将捕获并默默地忽略所有正常异常(这在大多数实际代码中仍然是不可取的,但在某些代码中绝对有效),同时允许其他异常通过。请注意,CancelledError、SystemExit、KeyboardInterrupt 和其他几个仍然会通过。如果您不喜欢退出时引起的“噪音”,那么您应该(最有可能)在更高级别专门捕获它们。
如果你真的想吞下除了 CancelledError 之外的所有东西,那么你会这样做:
try:
... (your code here)
except asyncio.CancelledError:
raise # avoid swallowing this one exception
except BaseException:
pass # silently swallow everything else: usually not a good idea