讲师中心 微信公众号
AI工具推荐 视频效率加速

asyncio.Condition 如何实现跨协程的等待与通知

阿萱酱_1578

阿萱酱_1578

发布时间:2026-01-24 16:13:02

|

158人浏览过

|

来源于php中文网

原创

asyncio.Condition需配合Lock使用,用于等待条件成立:wait()自动释放锁并挂起,唤醒后重获锁;notify()无需持锁但应在锁内修改状态后调用;必须用while循环双重检查条件,且条件变量须受锁保护。

asyncio.condition 如何实现跨协程的等待与通知

asyncio.Condition 的基本用法和核心逻辑

它不是用来替代 asyncio.Lock 的,而是配合锁一起用,解决「等某个条件成立再继续」的问题。本质是:一个协程在锁保护下检查条件,不满足就挂起;另一个协程修改状态后通知等待者。关键点在于——wait() 会自动释放关联的锁,挂起当前协程;被 notify() 唤醒后,会重新获取锁再返回。

  • asyncio.Condition 必须传入一个 asyncio.Lock(或 asyncio.RLock),不能裸用
  • wait() 只能在已持有锁的前提下调用,否则抛 RuntimeError: await was called on a coroutine with no running event loop 或更常见的 RuntimeError: cannot wait on a condition not owned by the current task
  • notify() 和 notify_all() 不要求当前协程持有锁,但通常应在锁保护下修改完共享状态后再调用,避免竞态

典型错误:忘记在 wait 前加锁,或在 notify 后没改状态

最常踩的坑是写成这样:

cond = asyncio.Condition()
# 错误:没加锁就 wait
await cond.wait()  # RuntimeError

或者:

async def waiter():
    async with cond:
        while not data_ready:
            await cond.wait()  # 等待,但 data_ready 永远不会变
<p>async def notifier():</p><div class="aritcle_card flexRow">
                                                        <div class="artcardd flexRow">
                                                                <a class="aritcle_card_img" href="/xiazai/skill9965" title="macOS UI 自动化技能包 —— 用 Python 控制你的 Mac"><img
                                                                                src="https://img.php.cn/upload/skill/001/246/273/6adaf20dbae7c507.jpg" alt="macOS UI 自动化技能包 —— 用 Python 控制你的 Mac" ></a>
                                                                <div class="aritcle_card_info flexColumn">
                                                                        <a href="/xiazai/skill9965" title="macOS UI 自动化技能包 —— 用 Python 控制你的 Mac">macOS UI 自动化技能包 —— 用 Python 控制你的 Mac</a>
                                                                        <p>让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac,无需学习 AppleScript

系统要求
macOS 14+ (Sonoma)

Python 3.9+

需要开启:辅助功能 + 屏幕录制权限</p>
                                                                </div>
                                                                <a href="/xiazai/skill9965" title="macOS UI 自动化技能包 —— 用 Python 控制你的 Mac" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
                                                        </div>
                                                </div><h1>错误:没改 data_ready 就 notify</h1><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">cond.notify()  # 等待者醒来,发现 data_ready 还是 False,又进 wait</code>

正确模式必须是「锁内检查 → 不满足则 wait → wait 返回后再次检查」,即经典的 double-check:

async with cond:
    while not data_ready:
        await cond.wait()
    # 此时 data_ready 为 True,且已持锁

notify() 和 notify_all() 的行为差异与适用场景

notify(n=1) 默认只唤醒一个等待协程,适合「生产者-消费者」中单个任务取走一项工作的场景;<code>notify_all() 唤醒全部,适合「状态广播」类需求,比如配置重载完成、服务启动就绪等。

  • 唤醒顺序不保证 FIFO,取决于事件循环调度,不要依赖唤醒次序
  • notify(0) 是合法调用,但什么也不做;notify(5) 在只有 2 个协程等待时,只唤醒 2 个
  • 被唤醒的协程不会立刻执行,要等当前持有锁的协程退出 async with 块后,才能重新抢到锁并继续

实际使用中容易忽略的复杂点

Condition 本身不保存状态,所有条件判断逻辑(比如 data_ready)必须由你用外部变量或对象属性维护,且读写需在锁保护下进行。这意味着你得自己管理「状态可见性」——Python 的内存模型不保证跨协程的变量修改立即可见,所以不能把条件判断写在锁外。

  • 别用全局布尔变量做条件,除非它被封装在锁保护的类里
  • 多个 Condition 共享同一把锁是允许的,但每个 Condition 应对应一类独立条件,混用会导致语义混乱
  • 如果等待逻辑可能超时,要用 asyncio.wait_for(await cond.wait(), timeout=...),但注意:超时异常抛出时,协程仍处于等待队列中,需确保后续有 notify 清理,否则造成泄漏

热门AI工具

更多
SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

相关专题

更多
while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

354

2023.09.25

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

4208

2025.08.29

C++中int、float和double的区别
C++中int、float和double的区别

本专题整合了c++中int和double的区别,阅读专题下面的文章了解更多详细内容。

804

2025.10.23

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

100

2026.10.22

Gradle Wrapper配置教程
Gradle Wrapper配置教程

本专题介绍Gradle Wrapper的基本作用,涵盖文件组成、生成方法、版本配置和任务调用,帮助你理解项目如何使用指定的Gradle版本,减少不同开发环境带来的构建差异。

60

2026.10.22

Golangci-lint检查器使用教程
Golangci-lint检查器使用教程

本专题整理Golangci-lint常用Linters的用途与配置方法,覆盖错误处理、无效代码、安全、复杂度、命名和依赖检查,帮助项目合理选规则。

60

2026.10.22

Gradle怎么构建Java项目
Gradle怎么构建Java项目

本专题介绍Gradle Java项目构建方法,涵盖Java插件配置、依赖声明、源码编译、测试执行和打包检查,帮助你理解各阶段的任务关系,逐步完成项目构建。

20

2026.10.22

PHP时间戳漏洞修复教程
PHP时间戳漏洞修复教程

本专题汇总PHP常见时间戳漏洞,包括2038年溢出、时区漂移、时间戳伪造、重放攻击、时间盲注与日志审计失效等,并给出升级64位环境、使用 DateTimeImmutable、统一UTC、严格超时校验、预处理绑定、hash_equals 比对等修复方案,帮助开发者快速排查和加固时间相关代码。

60

2026.10.22

Golangci-lint配置文件与规则设置
Golangci-lint配置文件与规则设置

本专题聚焦Golangci-lint YAML配置文件,讲清运行参数、规则启停、目录排除、问题过滤及严重级别设置,便于团队统一检查标准。

20

2026.10.22

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Uvicorn官方安装与入门手册
Uvicorn官方安装与入门手册

共0课时 | 0人学习

Python uv官方项目管理指南
Python uv官方项目管理指南

共0课时 | 0人学习

Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn