如何处理Pythonasyncio中的CancelledError()异常

在Python的asyncio模块中，CancelledError是一个特殊的异常类，当一个协程被取消时会引发该异常。协程的取消可以由其他协程或调用者发起。本文将介绍如何处理CancelledError异常，并提供一个使用例子。

处理CancelledError异常的方法有以下几种：

1. 使用try/except块捕获异常：可以在使用await语句等待一个协程时使用try/except块来捕获CancelledError异常，并在异常处理中执行相应的操作。下面是一个使用try/except块处理CancelledError异常的示例：

import asyncio

async def my_coroutine():
    try:
        await asyncio.sleep(1)
    except asyncio.CancelledError:
        print("Coroutine was cancelled")

async def main():
    task = asyncio.create_task(my_coroutine())
    await asyncio.sleep(0.5)
    task.cancel()
    await task

asyncio.run(main())

在上面的例子中，我们创建了一个名为my_coroutine的协程。在main函数中，我们使用asyncio.create_task创建了一个Task对象来调度my_coroutine的执行。然后我们等待0.5秒后取消了该任务。在my_coroutine中，我们使用try/except块捕获CancelledError异常，并在异常处理中打印出一条消息。

2. 继承asyncio.CancelledError并定义自己的异常类：如果希望在处理CancelledError异常时执行一些特定的操作，可以定义一个继承自CancelledError的异常类，并在其中实现相应的逻辑。下面是一个示例：

import asyncio

class CustomCancelledError(asyncio.CancelledError):
    def __init__(self, message="Coroutine was cancelled"):
        super().__init__(message)

async def my_coroutine():
    try:
        await asyncio.sleep(1)
    except CustomCancelledError as e:
        print(e)

async def main():
    task = asyncio.create_task(my_coroutine())
    await asyncio.sleep(0.5)
    task.cancel()
    await task

asyncio.run(main())

在上面的例子中，我们定义了一个名为CustomCancelledError的异常类，它继承自asyncio.CancelledError。在my_coroutine中，我们使用try/except块捕获CustomCancelledError异常，并在异常处理中打印出异常对象的消息。

无论是使用try/except块捕获CancelledError异常还是定义自己的异常类，处理CancelledError异常都可以帮助我们在协程取消时执行一些特定的操作或清理工作。

总结起来，处理Python的asyncio中的CancelledError异常可以通过使用try/except块捕获异常或者定义自己的异常类来实现。根据具体的需求，我们可以在异常处理中执行相应的操作。