ES6异步生成器配合for await...of可实现大文件按需加载，每次只读取并处理一行或一块数据，内存占用稳定在O(1)级别。
ES6 异步生成器（async function*）配合 for await...of，能在大文件读取中实现真正的按需加载——每次只把一行或一块数据拉进内存，处理完立刻释放，完全避开全量加载导致的内存暴涨。
核心机制：暂停执行 + 按需产出
异步生成器不是一次性读完文件，而是在每次 yield 后暂停，等消费者（比如 for await 循环）取走当前值、准备就绪后，再从上次暂停处继续读下一段。整个过程不缓存历史数据，调用栈和变量作用域也随每次迭代自然回收。
-
yield 返回的是 Promise：每个
yield后跟一个异步操作（如readline.readLine()），返回Promise<string>，由引擎自动await - 状态不累积：生成器内部不保存已处理的行，也不构建数组，只维护当前流位置和少量临时变量
-
错误可中断流程：某一行处理失败时，可直接
throw，无需清理大量中间数据
典型实现：基于 readline 的逐行读取
Node.js 中最稳妥的方式是用 fs.promises.open + readline.createInterface 构建异步可迭代接口，再用异步生成器封装逻辑：
- 先打开文件获取
FileHandle，避免createReadStream的内部缓冲不可控问题 - 将文件句柄转为可读流，传给
readline.createInterface，它会自动按\n切分并支持[Symbol.asyncIterator]() - 异步生成器内用
for await (const line of rl)迭代，每轮只持有当前行字符串
示例代码片段：
Javascript Sdk
下载
用于 inference.sh 的 JavaScript/TypeScript SDK，可运行 AI 应用、构建代理、集成 150+ 模型。包名：@inferencesh/sdk（npm install），完整 TypeScript 支持。
async function* readLines(filePath) {<br> const file = await fs.promises.open(filePath);<br> const rl = readline.createInterface({ input: file.createReadStream() });<br> try {<br> for await (const line of rl) {<br> yield line.trim(); // 只产出清洗后的行，不保留原始换行符<br> }<br> } finally {<br> await file.close();<br> rl.close();<br> }<br>}
进阶技巧：跳过头部、控制缓冲、提前终止
实际场景中常需灵活干预读取行为，异步生成器天然支持这些操作：
-
跳过表头：在
for await外加一层await rl[Symbol.asyncIterator]().next()消费首行，不yield -
限制读取行数：用计数器 +
break，循环结束即停止流消费，底层流自动暂停或销毁 -
自定义分块大小：不依赖
readline，改用file.read(buffer)手动解析换行符，适合超长行或二进制混合文本 -
组合过滤逻辑：在
yield前做轻量判断（如if (line.includes('ERROR')) yield line），无效行不进入后续流程
对比同步生成器与纯异步迭代的区别
同步生成器（function*）无法真正解决 I/O 阻塞——若底层用 fs.readFileSync，仍会卡主线程；而异步生成器强制所有 I/O 走 Promise 链，保证事件循环畅通。更重要的是：它让“流式”有了时间维度：内存占用不仅低，还稳定在 O(1) 级别（仅当前行+缓冲区），不受文件总行数影响。
