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)的问题。同时,协程还可以帮助你更有效地利用系统资源,提高程序的性能。