一、 协程的竞态条件：为什么单线程也需要锁？

共享账户余额为 100 元  async def withdraw(amount):     global shared_balance     print(f"开始取款: {amount} 元")          # 模拟查询数据库网络延迟（此时协程被挂起，让出 CPU）     await asyncio.sleep(1)          # 重新获得 CPU 后的扣减逻辑     if shared_balance >= amount:         shared_balance -= amount         print(f"成功取出 {amount} 元，剩余余额: {shared_balance} 元")     else:         print("余额不足，取款失败！")  async def main():     # 并发执行两个取款任务，总额度超出 100 元     await asyncio.gather(withdraw(80), withdraw(80))  # 运行结果： # 成功取出 80 元，剩余余额: 20 元 # 成功取出 80 元，剩余余额: -60 元 （账户透支了！发生了竞态错误）

二, asyncio.Lock（异步锁）的解决方案

创建异步锁  async def safe_withdraw(amount):     global shared_balance     # 使用 async with 语法自动获取和释放锁     async with lock:         print(f"开始安全取款: {amount} 元")         await asyncio.sleep(1)  # 即使在此挂起，其他协程也无法进入临界区         if shared_balance >= amount:             shared_balance -= amount             print(f"成功取出 {amount} 元，剩余余额: {shared_balance} 元")         else:             print("余额不足，取款失败！")

三、 asyncio.Event（异步事件通知）

挂起等待事件激活     print(f"任务 {task_id}：数据库已就绪，开始读取数据。")  async def init_database():     print("正在连接数据库并初始化数据...")     await asyncio.sleep(3)  # 模拟初始化耗时     print("数据库初始化完成！")     db_connected_event.set()  # 发送广播信号，唤醒所有等待的协程  async def main():     # 并发运行多个数据处理协程和初始化协程     await asyncio.gather(         fetch_api_data(1),         fetch_api_data(2),         init_database()     )

四、 asyncio.Queue（异步队列）

获取任务，如果队列为空则挂起等待         task = await queue.get()         print(f"消费者：正在处理 {task}")         await asyncio.sleep(1)         queue.task_done()  # 通知队列该任务已处理完毕  async def main():     queue = asyncio.Queue()     # 启动消费者（后台守护任务）     consumer_task = asyncio.create_task(consumer(queue))          # 运行生产者，直至其结束     await producer(queue)          # 等待队列中所有任务被处理完毕 (queue.join())     await queue.join()     consumer_task.cancel()  # 取消消费者任务

五、 总结