python / python/cpython

Implement `anext` and `aiter` in pure Python

未关闭
#157,361 8 条评论 2 个 reaction 已指派 1 人 在 GitHub 查看

@kumaraditya303 已经在做这个了。

开始于 2026年9月12日。

3.16 interpreter-core topic-asyncio type-feature
主要语言
Python
星标
77.2k
派生
35.9k
PR 合并指标
PR 指标待抓取

描述

Feature or enhancement

Feature or enhancement

I propose to implement anext() and aiter() in Python instead of C, compiled at interpreter startup and copied into builtins. This removes the private anext_awaitable, async_callable_iterator and async_callable_iterator_awaitable types.

anext(it, default) becomes a plain coroutine that awaits type(it).__anext__(it) and converts StopAsyncIteration into the default. The callable form of aiter() (gh-64862) becomes a small class with async def __anext__ that calls and awaits the callable and turns the sentinel or stop_exception into StopAsyncIteration. Semantics stay the same.

The motivation is #157032 and #157044: the C awaitables break the asyncio await graph. capture_call_graph walks cr_await/ag_await, and these types have neither, so the graph stops at the frame calling anext(it, default) or iterating aiter(callable, sentinel) and hides where the task is actually suspended. This would fix #157032, #157044 without any special casing.

Repro with a class-based async iterator:

import asyncio

async def fetch():
    await asyncio.sleep(10)

class AIter:
    def __aiter__(self): return self
    async def __anext__(self):
        await fetch()
        return 1

async def consumer():
    await anext(AIter(), None)

async def main():
    t = asyncio.create_task(consumer(), name="consumer")
    for _ in range(3):
        await asyncio.sleep(0)
    asyncio.print_call_graph(t)
    t.cancel()

asyncio.run(main())

Before:

* Task(name='consumer', id=0x10a42c7d0)
  + Call stack:
  |   File 'demo.py', line 13, in async consumer()

After:

* Task(name='consumer', id=0x108959b80)
  + Call stack:
  |   File 'Lib/asyncio/tasks.py', line 707, in async sleep()
  |   File 'demo.py', line 4, in async fetch()
  |   File 'demo.py', line 9, in async AIter.__anext__()
  |   File '<builtins>', line 26, in async _anext_with_default()
  |   File 'demo.py', line 13, in async consumer()
Linked PRs
  • gh-157362
  • gh-157687

贡献指南

打开贡献指南

从这里开始

  1. 先读完整个 Issue,再读项目的贡献指南。
  2. 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
  3. Fork 仓库,在一个分支上完成修改。
  4. 提交 Pull Request,并在描述里引用这个 Issue 编号。

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。