async for 遇到 StopAsyncIteration 会自动停止，无需手动捕获；自定义异步迭代器必须显式抛出该异常，异步生成器则在结束时自动触发。
async for 遇到 StopAsyncIteration 会自动停止，不用手动捕获
Python 的 async for 语句底层会自动调用异步迭代器的 __anext__()，并在收到 StopAsyncIteration 时干净退出——这和同步的 for 处理 StopIteration 完全一致。你不需要、也不应该用 try/except StopAsyncIteration 包裹 async for 循环。
常见错误是照搬同步思维，写成这样：
async for item in async_iter:
...
except StopAsyncIteration: # ❌ 语法错误：async for 不允许直接跟 except
pass或者试图手动调用 __anext__() 并自己处理异常：
while True:
try:
item = await async_iter.__anext__() # ✅ 可行但冗余
except StopAsyncIteration:
break # ✅ 逻辑正确，但绕过了语言设计初衷这种写法不仅啰嗦，还容易漏掉 __aenter__/__aexit__ 等上下文管理逻辑（比如异步生成器里的 async with 块）。
立即学习“Python免费学习笔记（深入）”；
自定义异步迭代器必须显式 raise StopAsyncIteration
如果你实现了自己的 __aiter__ 和 __anext__，必须在数据耗尽时主动 raise StopAsyncIteration。Python 不会帮你判断“该结束了”，也不会从返回值（比如 None）推断终止条件。
典型错误写法：
macOS UI 自动化技能包 —— 用 Python 控制你的 Mac
下载
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限
- 返回
None或空字符串代替抛出异常 →async for会无限等待或报TypeError: object NoneType can't be used in 'await' expression - 忘记
await在__anext__中的挂起操作（如await asyncio.sleep(0)），导致协程对象未被驱动 → 后续await报RuntimeWarning: coroutine 'X.__anext__' was never awaited
正确示例（有限次异步计数器）：
class AsyncCounter:
def __init__(self, n):
self.i = 0
self.n = n
<pre class='brush:python;toolbar:false;'>def __aiter__(self):
return self
async def __anext__(self):
if self.i >= self.n:
raise StopAsyncIteration # ✅ 必须显式抛出
self.i += 1
await asyncio.sleep(0) # 模拟异步操作
return self.i在异步生成器中 yield 后自动结束，无需额外操作
用 async def + yield 定义的异步生成器，函数自然返回时，解释器会自动转换为 StopAsyncIteration。这是最安全、最推荐的方式。
注意点：
- 不要在异步生成器里
return value（除return空语句外）→ 会触发SyntaxError: 'return' with argument inside async generator - 如果生成器内部有
async with或async for，确保它们能正常完成；否则可能卡在__aexit__，导致StopAsyncIteration永远不抛出 - 异步生成器中的异常（非
StopAsyncIteration）会原样向上冒泡，不会被吞掉
示例：
async def async_range(n):
for i in range(n):
await asyncio.sleep(0.01)
yield i
# 函数执行完自动结束，无需任何额外代码调试时如何确认 StopAsyncIteration 是否被正确触发
当 async for 表现为“卡住”或“提前退出”，问题往往不在异常处理本身，而在迭代器状态或生命周期上。
排查建议：
- 在自定义
__anext__开头加print(f"fetching {self.i}")，观察是否进入末尾分支并执行了raise StopAsyncIteration - 检查异步迭代器是否被重复使用：多数异步迭代器（尤其是异步生成器）是一次性的，第二次遍历时可能直接返回空迭代器或报错
- 确认事件循环没被意外关闭：如果在
__anext__中用了loop.create_task()之类操作，而循环已关闭，可能引发RuntimeError: Event loop is closed，掩盖真实问题 - 避免在
async for循环体中对同一迭代器再次async for—— 这不是并发问题，而是状态混乱的根源
最隐蔽的坑是：你以为在遍历一个新迭代器，其实拿到的是同一个已耗尽的对象。异步迭代器不像列表，没有“重置”机制。
