Python 协程(Coroutine)是一种轻量级的线程,它可以在执行过程中挂起并在稍后恢复。协程可以让你编写更简洁、高效的异步代码。在 Python 中,协程主要通过 async
和 await
关键字实现。
以下是协程如何简化编程的一些示例:
- 使用
async def
定义协程函数:
async def fetch_data(url): print(f"开始获取数据:{url}") # 假设这里是一个耗时操作,例如网络请求 await asyncio.sleep(1) print(f"获取数据完成:{url}") return {"url": url, "data": "这里是数据"}
- 使用
await
关键字调用协程函数:
async def main(): url1 = "https://api.example.com/data1" url2 = "https://api.example.com/data2" # 使用 await 关键字调用协程函数 result1 = await fetch_data(url1) result2 = await fetch_data(url2) print(result1) print(result2) # 运行协程 asyncio.run(main())
- 使用
asyncio.gather
并行执行多个协程:
async def main(): url1 = "https://api.example.com/data1" url2 = "https://api.example.com/data2" # 使用 asyncio.gather 并行执行多个协程 results = await asyncio.gather(fetch_data(url1), fetch_data(url2)) print(results) # 运行协程 asyncio.run(main())
- 使用
asyncio.create_task
创建任务:
async def main(): url1 = "https://api.example.com/data1" url2 = "https://api.example.com/data2" # 使用 asyncio.create_task 创建任务 task1 = asyncio.create_task(fetch_data(url1)) task2 = asyncio.create_task(fetch_data(url2)) # 等待所有任务完成 results = await asyncio.gather(task1, task2) print(results) # 运行协程 asyncio.run(main())
通过使用协程,你可以编写更简洁的异步代码,避免了回调地狱(Callback Hell)的问题。同时,协程还可以帮助你更有效地利用系统资源,提高程序的性能。