不能将__await__用作异步构造器,因其仅使已有实例可等待,不参与对象创建;正确做法是使用async def create()工厂方法分离异步初始化逻辑。

<strong>await</strong> 不能用于替代异步构造器,它只是让实例支持 await 语法,但不解决初始化问题;真正可行的路径是放弃在 <strong>init</strong> 中做异步操作,改用显式的异步工厂方法。
为什么不能把 __await__ 当成异步构造器用
有人尝试给类实现 __await__,以为这样就能写 obj = await MyClass()。但这是误解:__await__ 是为已有实例提供可等待行为(比如让对象像协程一样被 await),它本身不参与对象创建过程。MyClass() 还是同步调用 __init__,而 __init__ 仍不能 await。
更关键的是,__await__ 返回的迭代器必须由你手动管理状态,稍有不慎就会导致事件循环卡住、资源未初始化就 await、或重复 await 引发异常。这不是初始化模式,而是“让实例变可等待”的技巧,适用场景极窄(如自定义 Future 类)。
-
__await__不会延迟__init__执行,对象在await前已构造完毕 - 若
__init__里没做任何事,而靠__await__去初始化,那首次await就成了隐式初始化入口——不可靠、难测试、无法控制调用时机 - FastAPI 等框架依赖类能被同步构造(例如依赖注入时),强行塞
__await__会导致启动失败或类型检查报错
正确做法:用 async def create(...) 工厂方法
把异步初始化逻辑从构造器中剥离,封装进一个独立的异步类方法。这是目前最清晰、最易测、最符合 async/await 语义的方案。
示例场景:需要连接 Cosmos DB 并确保数据库与容器存在:
class CosmosCRUD:
def __init__(self, client: CosmosClient):
self.client = client
self.database = None
self.container = None
<pre class="brush:php;toolbar:false;">@classmethod
async def create(cls, client: CosmosClient, db_name: str, container_name: str):
instance = cls(client)
instance.database = await client.create_database_if_not_exists(db_name)
instance.container = await instance.database.create_container_if_not_exists(
container_name, partition_key=PartitionKey(path="/id")
)
return instance
- 构造函数只做轻量赋值,不触发任何 I/O
-
create是显式、可命名、可文档化的异步入口,调用者清楚“这一步要 await” - 支持类型提示(
-> Coroutine[None, None, Self])、IDE 自动补全和 mypy 检查 - 便于单元测试:你可以 mock
client,然后直接await CosmosCRUD.create(...)
避免在 __init__ 里硬套 asyncio.run 或 loop.run_until_complete
这类写法看似“解决了问题”,实则埋下严重隐患:
- 如果当前线程已有运行中的事件循环(如 FastAPI/Uvicorn 启动后),
asyncio.run会抛出RuntimeError: asyncio.run() cannot be called from a running event loop -
loop.run_until_complete会阻塞当前线程,破坏异步上下文,导致整个服务吞吐量骤降 - 多线程环境下,
get_event_loop()可能返回错误的 loop 实例,引发竞态或死锁 - Python 3.12+ 已标记部分低层 loop API 为 deprecated,未来兼容性无保障
一句话:同步代码里强行驱动异步流程,等于在高速公路上开拖拉机——能动,但不该动,也不可持续。
补充:对“延迟初始化成员”的轻量需求,可用 asyncio.Lock + 属性缓存
如果某个耗时成员不是每次都要用,且你希望首次访问时才异步加载(比如配置、模型权重、大缓存),可以结合 asyncio.Lock 避免并发重复初始化:
class LazyLoader:
def __init__(self):
self._data = None
self._lock = asyncio.Lock()
self._initialized = False
<pre class="brush:php;toolbar:false;">async def get_data(self):
if self._initialized:
return self._data
async with self._lock:
if self._initialized:
return self._data
# 这里放真正的异步加载逻辑
self._data = await self._load_heavy_data()
self._initialized = True
return self._data
注意:这种模式适合“单次异步加载 + 多次复用”的场景,不适合需要每次重建的资源(如数据库连接)。它不替代工厂方法,而是作为其补充策略。
真正难处理的不是语法怎么写,而是想清楚“初始化”这件事该发生在哪一层:是框架启动时(应由 startup event 驱动),还是请求到来时(应由工厂或 lazy getter 承担),抑或根本该交给依赖注入容器(如 FastAPI 的 Depends)。混淆这些边界,再漂亮的 <strong>await</strong> 也救不了设计缺陷。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











