Python 中实现异步编程主要依赖于 `asyncio` 库，该库提供了完整的异步 I/O 框架，支持协程、任务、事件循环等核心概念。异步编程通过 `async/await` 语法实现非阻塞操作，尤其适用于 I/O 密集型任务，例如网络请求、文件读写等[^2]。 ### 异步编程的核心概念 - **协程（Coroutine）**：通过 `async def` 定义的函数，必须通过 `await` 或 `asyncio.create_task()` 来调度执行。 - **事件循环（Event Loop）**：负责调度和运行协程，是异步编程的核心。 - **任务（Task）**：将协程封装为任务，并由事件循环调度执行。 ### 示例代码 #### 1. 简单的异步函数示例 以下代码演示了如何定义和运行一个异步函数： ```python import asyncio async def say_hello(): print("Hello") await asyncio.sleep(1) print("World") asyncio.run(say_hello()) ``` 在该示例中，`say_hello()` 是一个协程，通过 `await asyncio.sleep(1)` 模拟了一个 I/O 操作。`asyncio.run()` 用于启动事件循环并执行协程[^1]。 #### 2. 异步迭代器示例 下面是一个自定义的异步迭代器，用于生成一系列数字： ```python import asyncio class Reader: """自定义异步迭代器（同时也是异步可迭代对象）""" def __init__(self): self.count = 0 async def readline(self): self.count += 1 if self.count == 100: return None return self.count def __aiter__(self): return self async def __anext__(self): val = await self.readline() if val is None: raise StopAsyncIteration return val async def main(): obj = Reader() async for item in obj: print(item) asyncio.run(main()) ``` 在该示例中，`Reader` 类实现了异步迭代器协议，包括 `__aiter__` 和 `__anext__` 方法。`main()` 函数通过 `async for` 遍历异步迭代器并打印值。 #### 3. 并发执行多个任务 异步编程的一个显著优势是能够并发执行多个任务。以下代码展示了如何使用 `asyncio.gather()` 同时运行多个协程： ```python import asyncio async def task(name, delay): print(f"{name} 开始") await asyncio.sleep(delay) print(f"{name} 结束") async def main(): task1 = task("任务A", 2) task2 = task("任务B", 1) task3 = task("任务C", 3) await asyncio.gather(task1, task2, task3) asyncio.run(main()) ``` 在上述代码中，三个任务并发执行，而不是按顺序等待每个任务完成。`asyncio.gather()` 用于并发调度多个协程。 #### 4. 异步网络请求示例 异步编程特别适合处理网络请求。以下代码使用 `aiohttp` 库进行异步 HTTP 请求： ```python import asyncio import aiohttp async def fetch_url(session, url): async with session.get(url) as response: return await response.text() async def main(): urls = [ "http://example.com", "http://example.org", "http://example.net" ] async with aiohttp.ClientSession() as session: tasks = [fetch_url(session, url) for url in urls] results = await asyncio.gather(*tasks) for result in results: print(result[:100]) # 打印响应内容的前100个字符 asyncio.run(main()) ``` 在该示例中，`aiohttp` 提供了异步 HTTP 客户端功能，`fetch_url()` 函数通过 `session.get()` 获取响应内容，而 `asyncio.gather()` 用于并发执行多个请求[^2]。 ### 总结 Python 的异步编程通过 `asyncio` 和 `async/await` 语法提供了强大的异步 I/O 支持，能够显著提高 I/O 密集型任务的执行效率。结合 `aiohttp`、`asyncpg` 等第三方库，可以轻松构建高性能的异步网络应用。