异步生成器函数(async function*)结合 for await...of 可优雅处理异步数据流,如分页请求、日志流等,通过 yield 返回 Promise 并由循环自动等待解析,实现同步式写法的异步迭代,提升代码可读性与维护性。

JavaScript的异步迭代器与生成器能自然协作,让开发者用同步写法处理异步数据流。它们通过 async function* 和 for await...of 结合使用,实现清晰、可读性强的异步序列处理。
异步生成器函数(Async Generator Functions)
异步生成器是使用 async function* 定义的函数,它结合了生成器和异步函数的特性:
- 可以使用 yield 暂停执行,并返回异步结果
- 每个 yield 可以配合 await 处理 Promise
- 返回一个既是异步迭代器又是生成器对象的实例
async function* fetchUsers() {
const pages = [1, 2, 3];
for (const page of pages) {
const response = await fetch(`/api/users?page=${page}`);
const users = await response.json();
yield users; // 每次返回一页用户
}
}使用 for await...of 消费异步迭代器
异步生成器返回的对象支持异步迭代协议,可以用 for await...of 遍历:
- 自动等待每个 yield 返回的 Promise 解决
- 按顺序处理异步产生的值
- 语法接近同步循环,降低心智负担
(async () => {
for await (const users of fetchUsers()) {
console.log(`Received ${users.length} users`);
// 逐批处理数据,无需等待全部加载完成
}
})();实际应用场景:流式数据处理
这种组合特别适合处理流式或分页数据:
立即学习“Java免费学习笔记(深入)”;
- 文件逐块读取:Node.js 中读取大文件时,一边读一边处理
- WebSocket 消息流:将实时消息封装为异步生成器,方便消费
- 数据库游标遍历:异步生成每条记录,避免一次性加载大量数据
async function* readLogs() {
let line;
while (line = await getNextLogLine()) {
if (line === null) break;
yield parseLog(line);
}
}
// 使用时像同步代码一样简洁
for await (const log of readLogs()) {
analyze(log);
}
基本上就这些。异步生成器提供了一种优雅方式来封装异步数据源,而 for await...of 让消费这些数据变得直观。两者协同工作,让复杂异步流程看起来更接近传统循环,提升代码可维护性。










