asyncio：是否可以取消执行者运行的未来

Python

使用 asyncio 可以方便地实现异步编程，但在某些情况下，我们可能需要取消正在执行的未来（Future）。本文将介绍如何在 asyncio 中取消执行者运行的未来，并提供一个案例代码来说明其用法。

在 asyncio 中，未来（Future）是一个表示异步操作结果的对象。我们可以使用 asyncio.create_task() 函数创建一个任务（Task），并将其提交给事件循环（Event Loop）进行处理。然后，我们可以使用 asyncio.Task.cancel() 方法来取消正在执行的任务。

取消未来（Cancel a Future）

要取消一个未来，我们只需要简单地调用未来对象的 cancel() 方法即可。下面是一个简单的示例代码，演示了如何取消一个未来：

Python
import asyncio
async def my_task():
    try:
        while True:
            print("Running...")
            awAIt asyncio.sleep(1)
    except asyncio.CancelledError:
        print("Task cancelled.")
async def mAIn():
    task = asyncio.create_task(my_task())
    awAIt asyncio.sleep(3)
    task.cancel()
asyncio.run(mAIn())

在上面的代码中，我们定义了一个名为 my_task() 的异步函数，它会一直打印 "Running..."，并每隔一秒钟暂停一次。然后，我们在 mAIn() 函数中创建了一个任务，并等待 3 秒钟后取消它。取消任务后，my_task() 函数将捕获到 asyncio.CancelledError 异常，并打印出 "Task cancelled."。

取消未来的影响

当我们取消一个未来时，它会导致任务终止，并引发 asyncio.CancelledError 异常。我们可以在异步函数中使用 try-except 块来捕获该异常，并在捕获到异常时执行相应的操作。例如，我们可以在捕获到异常时进行资源清理或打印错误日志。

另外，值得注意的是，取消未来并不会立即停止任务的执行。取消操作只是向任务发送一个取消请求，任务会在某个适当的时机检查是否被取消，并在下一个合适的取消点处停止执行。在上面的示例代码中，我们使用了 asyncio.sleep() 函数来模拟任务执行期间的取消点。

取消未来的注意事项

在使用 asyncio 取消未来时，需要注意以下几点：

1. 取消未来只能在协程函数中进行，不能在普通函数或异步上下文管理器中进行。

2. 取消未来不会影响已经完成的未来。只有处于运行中的未来才能被取消。

3. 取消未来可能会导致未来对象引发 asyncio.CancelledError 异常，我们可以在协程函数中使用 try-except 块来捕获该异常。

使用 asyncio 可以方便地取消执行者运行的未来。本文介绍了如何在 asyncio 中取消未来，并提供了一个简单的案例代码来说明其用法。我们还讨论了取消未来的影响和注意事项。通过合理使用取消未来的功能，我们可以更好地控制异步任务的执行。