asyncio.Event是协程安全的布尔标志,仅含“已设置/未设置”状态,需配对使用set()和clear()实现单次通知;误用易致虚假唤醒,复杂场景推荐asyncio.Queue。

asyncio.Event 本质是协程安全的布尔标志
asyncio.Event 不是信号量(asyncio.Semaphore),它没有计数能力,只提供「已设置 / 未设置」两种状态。它的核心价值在于:让一个协程能 等待 另一个协程调用 set(),且整个过程不阻塞事件循环。常见误用是拿它当「发一次、收多次」的广播工具——但默认情况下,wait() 被唤醒后状态仍保持 True,后续 wait() 会立刻返回,除非手动 clear()。
跨协程通知必须配对使用 set() 和 clear()
若想实现「通知一次、只被消费一次」的效果(比如模拟信号量的 acquire/release 行为),必须显式管理状态生命周期:
- 发送方调用
event.set()后,通常应尽快调用event.clear(),否则下次wait()不会挂起 - 接收方在
await event.wait()返回后,应主动检查业务条件是否真正满足(避免虚假唤醒),再决定是否继续执行 - 多个协程同时
await event.wait()会全部被唤醒,但只有第一个可能拿到资源——需配合锁或队列做二次协调
替代方案:用 asyncio.Queue 实现带缓冲的通知
如果需要「多生产、单消费」或「保留通知历史」,asyncio.Event 就力不从心了。更稳妥的选择是 asyncio.Queue:
q = asyncio.Queue(maxsize=1)
# 发送通知(非阻塞,丢弃旧通知)
try:
q.put_nowait("signal")
except asyncio.QueueFull:
q.get_nowait() # 清掉旧的
q.put_nowait("signal")
接收方
msg = await q.get() # 真正阻塞等待
asyncio.Queue 天然支持跨协程、线程安全、可设容量,比手动维护 Event 状态更少出错。
本文档主要讲述的是Android传感器编程;传感器是一种物理装置或生物器官,能够探测、感受外界的信号、物理条件(如光、热、湿度)或化学组成(如烟雾),并将探知的信息传递给其它装置或器官。同时也可以说传感器是一种检测装置,能感受被测量的信息,并能将检测的感受到的信息,按一定规律变换成为电信号或其它所需形式的信息输出,以满足信息的传输、处理、存储、显示、记录和控制等要求。它是实现自动检测和自动控制的首要环节。感兴趣的朋友可以过来看看
容易忽略的陷阱:loop 不一致与 await 时机
两个常见崩溃点:
-
asyncio.Event必须在同一个事件循环中创建和使用;跨线程或跨 loop 创建会导致RuntimeError: a task is already running - 在
await event.wait()前,确保event.set()不会在当前协程刚挂起时就被调用——否则可能错过通知。保险做法是先set()再await wait(),或用asyncio.create_task()确保调度顺序
复杂场景下,别硬套 Event;通知语义越模糊,越该换 Queue 或 Condition。









