Python 并发程序中的常见坑点

发布时间 - 2026-01-29 00:00:00    点击率:
asyncio.run() 只能在顶层脚本入口调用,不可在已运行事件循环(如Jupyter、FastAPI)中重复使用;需用create_task()或await替代;协程必须显式await,否则不执行;共享状态须用asyncio.Lock()保护;CPU密集任务须用run_in_executor()或to_thread()卸载。

asyncio.run() 不能在已运行的事件循环中调用

这是新手最常遇到的 RuntimeError: asyncio.run() cannot be called from a running event loop。根本原因不是代码写错了,而是你在 Jupyter、IPython 或已启动 asyncio 的上下文(比如 FastAPI 启动后)里又调用了 asyncio.run()

解决方法很简单:只在顶层脚本入口用一次 asyncio.run()

在交互环境或已有事件循环中,改用 asyncio.create_task()await 直接执行协程。

  • ✅ 正确:脚本最外层 asyncio.run(main())
  • ❌ 错误:在 async def handler() 里再写 asyncio.run(another_coro())
  • ⚠️ 注意:asyncio.get_event_loop().run_until_complete() 在 Python 3.10+ 已不推荐,且在嵌套场景下行为更难预测

await 一个普通函数或未 await 的协程对象

常见现象是程序“看似跑完了”,但异步任务根本没执行——比如忘了在 asyncio.sleep(1) 前加 await,或者把 fetch_data()(返回协程对象)直接传给 print() 而不是 await fetch_data()

Python 不会报错,只会打印类似 ,而后续逻辑可能因变量类型错误崩溃。

  • ✅ 检查所有调用:确认函数是否带 async 声明,如果是,必须 await
  • ✅ 用 inspect.iscoroutine()inspect.iscoroutinefunction() 在调试时验证返回值类型
  • ⚠️ 特别注意第三方库:有些函数名像异步(如 aiohttp.ClientSession.get),但返回的是 ClientResponse 对象,真正要 await 的是它的 .text().json() 方法

共享状态未加锁导致竞态条件

很多人以为 “async 就是线程安全的”,结果在多个协程里同时修改一个全局列表或字典,出现数据丢失或索引错乱。asyncio 是单线程并发,但协程切换点(await)就是竞态窗口。

典型错误:多个协程都执行 results.append(data),但 append 不是原子操作(先读长度、再写入、再更新长度)。

  • ✅ 用 asyncio.Lock() 包裹临界区,不是 threading.Lock
  • ✅ 更推荐无状态设计:每个协程生成独立结果,最后用 asyncio.gather() 收集,避免共享可变状态
  • ⚠️ asyncio.Queue 是线程/协程安全的,适合生产者-消费者模式;但直接读写普通 dict/list 一律视为不安全

长时间 CPU 密集型操作阻塞整个事件循环

asyncio 不是万能加速器。如果你在协程里写了个 for i in range(10**7): total += i,整个事件循环就卡死了——因为没 await,就没有让出控制权的机会。

这种问题在本地测试时不易察觉(小数据量快),一上生产就暴露:HTTP 超时、心跳断连、其他协程饿死。

  • ✅ CPU 密集任务必须移出事件循环:用 loop.run_in_executor() 丢给线程池或进程池
  • ✅ 用 asyncio.to_thread()(Python 3.9+)替代手写 executor 调用,更简洁
  • ⚠️ 不要用 time.sleep(),它会彻底阻塞;必须用 await asyncio.sleep()

真正难处理的从来不是“怎么写 async”,而是判断哪些操作必须 await、哪些必须 offload、哪些压根不该放进协程里。边界模糊的地方,往往藏在第三方库文档的角落,或你自己的 for 循环里。


# python  # js  # json  # app  # session  # ai  # 解决方法  # 异步任务  # 数据丢失  # fastapi  # ipython  # print  # for  # 变量类型  # 循环  # 值类型  # Event  # 线程  # append  # 并发  # 对象  # 事件  # 异步  # jupyter  # http  # 的是  # 多个  # 你在  # 第三方  # 自己的  # 再写  # 这是  # 已有  # 死了  # 很多人 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Laravel怎么发送邮件_Laravel Mail类SMTP配置教程  详解Huffman编码算法之Java实现  Thinkphp 中 distinct 的用法解析  JS碰撞运动实现方法详解  Laravel如何使用Socialite实现第三方登录?(微信/GitHub示例)  微信小程序 五星评分(包括半颗星评分)实例代码  Windows驱动无法加载错误解决方法_驱动签名验证失败处理步骤  jQuery中的100个技巧汇总  Win11怎么恢复误删照片_Win11数据恢复工具使用【推荐】  阿里云网站搭建费用解析:服务器价格与建站成本优化指南  零服务器AI建站解决方案:快速部署与云端平台低成本实践  如何在IIS中新建站点并配置端口与IP地址?  专业型网站制作公司有哪些,我设计专业的,谁给推荐几个设计师兼职类的网站?  Laravel如何使用Facades(门面)及其工作原理_Laravel门面模式与底层机制  Laravel如何实现数据导出到PDF_Laravel使用snappy生成网页快照PDF【方案】  微信小程序 scroll-view组件实现列表页实例代码  Win11怎样安装网易有道词典_Win11安装词典教程【步骤】  Laravel如何从数据库删除数据_Laravel destroy和delete方法区别  Laravel怎么生成二维码图片_Laravel集成Simple-QrCode扩展包与参数设置【实战】  Laravel Admin后台管理框架推荐_Laravel快速开发后台工具  Laravel怎么创建控制器Controller_Laravel路由绑定与控制器逻辑编写【指南】  Laravel怎么使用artisan命令缓存配置和视图  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  Laravel Facade的原理是什么_深入理解Laravel门面及其工作机制  Win11任务栏卡死怎么办 Windows11任务栏无反应解决方法【教程】  百度输入法ai面板怎么关 百度输入法ai面板隐藏技巧  在线教育网站制作平台,山西立德教育官网?  Python进程池调度策略_任务分发说明【指导】  如何在IIS7中新建站点?详细步骤解析  Laravel如何连接多个数据库_Laravel多数据库连接配置与切换教程  详解jQuery停止动画——stop()方法的使用  5种Android数据存储方式汇总  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办?  Laravel如何生成API文档?(Swagger/OpenAPI教程)  品牌网站制作公司有哪些,买正品品牌一般去哪个网站买?  网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面?  如何在沈阳梯子盘古建站优化SEO排名与功能模块?  Laravel如何使用Telescope进行调试?(安装和使用教程)  Python函数文档自动校验_规范解析【教程】  Laravel 419 page expired怎么解决_Laravel CSRF令牌过期处理  如何实现javascript表单验证_正则表达式有哪些实用技巧  为什么php本地部署后css不生效_静态资源加载失败修复技巧【技巧】  如何快速生成可下载的建站源码工具?  如何快速生成高效建站系统源代码?  个人网站制作流程图片大全,个人网站如何注销?  Laravel Eloquent关联是什么_Laravel模型一对一与一对多关系精讲  Windows家庭版如何开启组策略(gpedit.msc)?(安装方法)  Linux系统命令中screen命令详解  Laravel如何配置任务调度?(Cron Job示例)  音响网站制作视频教程,隆霸音响官方网站?