Python 异步编程：使用 async/await 实现高效并发 - 指南

异步编程的必要性

在处理I/O密集型应用时，同步编程往往效率低下。例如，在网络请求或文件读写时，程序会因等待I/O而“阻塞”，导致资源浪费。为解决这一问题，异步编程应运而生。

传统同步模型中，代码按顺序执行，每一步都需等待前一步完成。而异步模型允许程序在等待I/O时切换到其他任务，从而提升性能。Python通过async def定义协程（coroutine），使用await等待异步操作完成。

import asyncio
async def fetch_data():
await asyncio.sleep(1)  # 模拟I/O操作
return "Data fetched"
async def main():
result = await fetch_data()
print(result)
asyncio.run(main())

此代码展示了基本的异步结构：async def定义协程，await等待结果。异步编程的核心是事件循环（event loop），它调度多个协程，实现并发执行。

异步函数与协程

在 Python 中，使用 async def 定义的函数称为协程（coroutine）。协程是一种可以暂停执行并稍后恢复的函数，常用于异步编程。它与生成器（generator）有相似之处，但更适用于 I/O 密集型任务。

await 是用于等待一个协程完成的关键字。当程序遇到 await 时，会暂停当前协程的执行，将控制权交还给事件循环（event loop），以便其他任务可以运行。一旦被等待的对象返回结果，协程会从暂停处继续执行。

与 yield 不同，await 用于等待异步操作，而 yield 用于生成值并暂停生成器。在现代异步编程中，推荐使用 async/await 而不是传统的 yield 和 yield from。

以下是一个简单的示例：

import asyncio
async def say_hello():
await asyncio.sleep(1)
print("Hello, world!")
asyncio.run(say_hello())

此代码定义了一个异步函数 say_hello，并在 asyncio.run() 中执行。await asyncio.sleep(1) 模拟了一个耗时的 I/O 操作，随后打印消息。通过这种方式，Python 实现了非阻塞的并发执行。

事件循环与异步任务管理

在 Python 的 asyncio 模块中，事件循环（Event Loop） 是运行异步程序的核心机制。它负责调度和执行异步任务，确保多个协程能够并发运行，而不是阻塞等待。

要启动一个 asyncio 程序，最简单的方式是使用 asyncio.run() 函数。它会创建一个新的事件循环，运行指定的协程，并在完成后关闭循环。例如：

import asyncio
async def main():
print("Starting main")
await asyncio.sleep(1)
print("Finishing main")
asyncio.run(main())

这段代码会在 1 秒后打印 “Finishing main”。

协程的调度与任务管理

asyncio.create_task() 可以将协程包装成一个 任务（Task），并将其提交到事件循环中。这允许你同时运行多个协程。例如：

import asyncio
async def work(task_id