Python3.8Asyncio-从字典列表返回结果

基础概念

asyncio 是 Python 3.4 引入的一个库，用于编写并发代码，使用异步 I/O 操作。它基于事件循环（event loop）的概念，允许你编写单线程并发代码，通过协程（coroutines）实现非阻塞的 I/O 操作。

相关优势

1. 提高性能：通过异步 I/O，可以在等待 I/O 操作完成时执行其他任务，从而提高程序的整体性能。
2. 简化并发编程：相比于多线程或多进程，异步编程模型更简单，避免了复杂的线程同步和锁机制。
3. 资源利用率高：单线程并发模型减少了线程切换的开销，提高了资源利用率。

类型

asyncio 主要涉及以下几种类型：

• 协程（Coroutine）：使用 async def 定义的函数。
• 任务（Task）：协程的包装器，用于并发执行协程。
• 事件循环（Event Loop）：管理协程的执行。

应用场景

asyncio 适用于需要处理大量 I/O 操作的场景，例如：

• 网络请求（HTTP 客户端、WebSocket 等）
• 文件读写
• 数据库操作

示例代码：从字典列表返回结果

假设我们有一个字典列表，需要异步地处理每个字典并返回结果。

import asyncio

async def process_dict(d):
    # 模拟异步操作，例如网络请求或数据库查询
    await asyncio.sleep(1)
    return {**d, 'processed': True}

async def main():
    dicts = [
        {'id': 1, 'name': 'Alice'},
        {'id': 2, 'name': 'Bob'},
        {'id': 3, 'name': 'Charlie'}
    ]
    
    # 创建任务列表
    tasks = [process_dict(d) for d in dicts]
    
    # 并发执行任务并等待结果
    results = await asyncio.gather(*tasks)
    
    print(results)

# 运行事件循环
asyncio.run(main())

参考链接

• Python 官方文档 - asyncio

遇到的问题及解决方法

问题：为什么 asyncio.gather 会抛出 CancelledError？

原因：CancelledError 通常是由于事件循环被取消或关闭导致的。

解决方法：

1. 确保事件循环正确关闭：
2. 确保事件循环正确关闭：
3. 检查任务取消逻辑：
4. 检查任务取消逻辑：

通过以上方法，可以更好地理解和处理 asyncio 中的常见问题。