迭代器模式与生成器函数结合，通过惰性求值实现高效数据流处理。生成器函数以<
code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>暂停执行，按需生成值，避免内存溢出，尤其适合无限序列或大型数据流。传统数组和循环因饥饿求值和状态管理复杂难以应对，而生成器仅在调用<yieldcode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>时计算下一个值，内存占用小、资源消耗低。异步场景中，async function和<next()code class='language-default'>forcode>…of支持异步迭代，可处理分页请求、事件流等，结合<awaitcode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>可委托其他迭代器，构建灵活的数据管道，提升异步代码可读性与维护性。yield
JavaScript的迭代器模式与生成器函数的结合，在我看来，是处理数据流，尤其是那些没有明确边界或需要按需生成的数据流时，一种极其优雅且高效的方案。简单来说，迭代器定义了“如何一步步获取下一个值”的协议，而生成器函数则是实现这个协议的“语法糖”，它让编写自定义迭代逻辑变得异常简单，特别是对于无限序列或惰性计算的场景。它们共同简化了我们对数据流的生成与消费，将复杂的内部状态管理和流程控制抽象化，使得代码更具可读性和可维护性。
解决方案
要深入理解迭代器模式与生成器函数的结合，我们得先分别看看它们各自扮演的角色，然后才能体会到它们联手后的强大。
迭代器模式，在JavaScript中，本质上是一个实现了
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法的对象。这个
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法每次被调用时，都会返回一个包含
<code class='language-default'>valuecode>
（当前值）和
<code class='language-default'><code class='language-default'>donecode>code>
（是否遍历结束）属性的对象。当
<code class='language-default'><code class='language-default'>donecode>code>
为
<code class='language-default'>truecode>
时，意味着迭代完成。任何实现了
<code class='language-default'>Symbol.iteratorcode>
方法的对象（该方法返回一个迭代器对象）都被认为是可迭代的。
<code class='language-default'><code class='language-default'><code class='language-default'>forcode>...ofcode>code>
循环就是基于这个协议工作的。
// 示例：一个简单的自定义迭代器，生成0到2的数字 function createRangeIterator(start, end) { let current = start; <code class='language-default'>returncode> { [<code class='language-default'>Symbol.iteratorcode>]() { // 使得这个对象本身也是可迭代的 <code class='language-default'>returncode> this; }, <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>next()code class='language-default'>returncode> { <code class='language-default'>valuecode>: current++, <code class='language-default'><code class='language-default'>donecode>code>: false }; } else { <code class='language-default'>returncode> { <code class='language-default'>valuecode>: undefined, <code class='language-default'><code class='language-default'>donecode>code>: <code class='language-default'>truecode> }; } } }; } const myRange = createRangeIterator(0, 2); <code class='language-default'>forcode> (const num of myRange) { console.log(num); // 0, 1, 2 }
生成器函数（
<code class='language-default'>function*code>
）则是一个更高级别的抽象，它能让你以一种更直观的方式来编写迭代器。当调用一个生成器函数时，它并不会立即执行，而是返回一个生成器对象（Generator Object）。这个生成器对象本身就是迭代器，因为它实现了
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法。生成器函数内部使用
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
关键字来“暂停”执行并返回一个值。每次调用生成器对象的
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法，函数就会从上次
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
的地方继续执行，直到遇到下一个
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
或
<code class='language-default'>returncode>
。
// 示例：使用生成器函数实现上述范围迭代 <code class='language-default'>function*code> generateRange(start, end) { <code class='language-default'>forcode> (let i = start; i <= end; i++) { <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> i; // 暂停执行，返回i } }yieldconst myGeneratorRange = generateRange(0, 2); <code class='language-default'>forcode> (const num of myGeneratorRange) {console.log(num); // 0, 1, 2 } // 或者手动调用<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code> //next()console.log(myGeneratorRange.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>); // { <next()code class='language-default'>valuecode>: 0, <code class='language-default'><code class='language-default'>donecode>code>: false } //console.log(myGeneratorRange.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>); // { <next()code class='language-default'>valuecode>: 1, <code class='language-default'><code class='language-default'>donecode>code>: false } //console.log(myGeneratorRange.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>); // { <next()code class='language-default'>valuecode>: 2, <code class='language-default'><code class='language-default'>donecode>code>: false } //console.log(myGeneratorRange.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>); // { <next()code class='language-default'>valuecode>: undefined, <code class='language-default'><code class='language-default'>donecode>code>: <code class='language-default'>truecode> }
它们结合起来的威力，尤其体现在处理无限数据流上。生成器函数的“暂停/恢复”机制完美契合了惰性求值的理念：只有当消费者请求下一个值时，生成器才会计算并
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
它。这对于那些理论上可以无限生成的数据（比如自然数序列、斐波那契数列、或者一个永不停止的事件流）来说，是不可或缺的。你不需要一次性在内存中创建所有数据，因为那是不可能的；你只需要一个生成器，它知道如何根据需要生成下一个数据。
// 示例：一个生成无限斐波那契数列的生成器 <code class='language-default'>function*code> fibonacciSequence() { let a = 0; let b = 1; while (<code class='language-default'>truecode>) { // 理论上无限 <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> a; [a, b] = [b, a + b]; // ES6解构赋值，交换并计算下一个 } }yieldconst fibGen = fibonacciSequence();console.log(fibGen.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 0console.log(fibGen.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 1console.log(fibGen.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 1console.log(fibGen.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 2console.log(fibGen.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 3 // 我们可以一直调用<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>，它会按需生成下一个斐波那契数，而不会耗尽内存next()
通过这种方式，生成器函数作为迭代器的工厂，极大地简化了无限数据流的生成逻辑。而消费者（如
<code class='language-default'><code class='language-default'><code class='language-default'>forcode>...ofcode>code>
循环或手动
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
调用）则以统一的迭代器协议来消费这些流，无论是有限还是无限。这种分离生成与消费的模式，让我们的代码更加模块化和高效。
为什么传统数组或循环难以处理无限数据流？
当我们谈论“无限数据流”时，传统的数据结构和控制流方式确实会遇到根本性的挑战。这并不是说它们“不好”，而是它们的设计初衷和适用场景不同。
首先，最显而易见的问题是内存限制。数组是内存中的一块连续区域，用来存储一系列元素。如果你试图将一个无限序列（比如所有的自然数）全部存储到一个数组中，那内存会瞬间被耗尽，程序崩溃是必然的。即使是“非常大但有限”的数据集，比如一个包含数十亿条记录的日志文件，如果尝试一次性读入内存并放入数组，也同样会面临内存溢出的风险。这种“一次性加载”的策略，我们称之为“饥饿求值”（eager evaluation），它要求所有数据在处理前都准备好。
其次，性能开销也是一个考量。即便不考虑内存，如果一个序列非常庞大，但我们可能只需要其中的一部分，那么预先生成所有数据无疑是巨大的浪费。例如，我们可能只需要斐波那契数列的前10000个数字中的第5000到第5010个，如果必须先计算出前10000个才能拿到这11个，那么前4999个和后面的数字的计算就成了不必要的开销。传统的
<code class='language-default'>forcode>
循环往往需要一个明确的结束条件，或者在循环内部进行复杂的逻辑判断来决定何时
<code class='language-default'><code class='language-default'>breakcode>code>
，这对于“按需获取”的场景显得笨重。
再者，状态管理复杂性也是一个痛点。在没有生成器的情况下，如果你想实现一个能够暂停和恢复的迭代逻辑，你可能需要手动维护大量的状态变量（比如当前索引、上一个值、上上个值等等），并将这些状态封装在一个闭包或者类中。每次迭代都需要显式地更新这些状态，并返回下一个值。这不仅增加了代码的复杂性，也更容易引入错误。比如，要实现斐波那契数列的迭代器，你需要一个外部变量来存储前两个数，每次迭代都要更新它们，这在逻辑上远不如生成器函数中的
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
和内部变量来得自然。
// 尝试用传统方式处理一个“无限”序列（这里用一个大数模拟） function getLargeSequenceBad(limit) { const result = []; <code class='language-default'>forcode> (let i = 0; i < limit; i++) { // 假设这里有一些复杂的计算 result.push(i * 2); } <code class='language-default'>returncode> result; } // 如果limit是Infinity，或者一个非常大的数，这会崩溃 // const infiniteData = getLargeSequenceBad(1e9); // 可能会导致内存溢出
总结来说，传统方法在处理无限或超大数据流时，由于其饥饿求值的特性、内存管理模式和手动状态维护的复杂性，显得力不从心。这正是迭代器和生成器函数结合的价值所在，它们提供了一种优雅的“惰性求值”解决方案。
生成器函数如何利用惰性求值优化资源消耗？
生成器函数在资源消耗优化方面的核心秘密，就在于其对惰性求值（Lazy Evaluation）的完美实现。它与传统的“饥饿求值”模式形成鲜明对比，后者会一次性计算并存储所有可能需要的数据。
惰性求值的基本思想是：“只在真正需要时才计算和生成数据。” 生成器函数通过
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
关键字将这一思想发挥到了极致。当一个生成器函数被调用时，它并不会立即执行函数体内的所有代码，而是返回一个生成器对象。这个对象就像一个承诺，表示它知道如何一步步地生成数据，但它不会主动去做，除非你要求它这样做。
每次你调用生成器对象的
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法，生成器函数才会从上次
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
暂停的地方继续执行，直到遇到下一个
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
语句。此时，它会返回
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
后面的值，并再次暂停执行，释放CPU资源。它的内部状态（局部变量、执行位置等）会被自动保存下来，等待下一次
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
调用时恢复。
这种机制带来的资源优化是多方面的：
-
内存占用极小： 这是最直接的优势。对于无限序列或超大数据集，你不需要在内存中存储整个序列。生成器在任何给定时间点，通常只需要在内存中维护极少量的状态（比如几个变量的值和当前的执行位置），而不是所有已生成或待生成的数据。这意味着你可以处理理论上无限的数据流，而不会耗尽系统内存。例如，一个生成器可以从一个巨大的文件中逐行读取数据，每次只在内存中保留一行，而不是将整个文件加载进来。
-
CPU资源按需分配： 只有当数据被消费时，相应的计算才会发生。如果消费者提前停止消费（例如，
<
code class='language-default'><code class='language-default'><code class='language-default'>forcode>...ofcode>code>循环中途
<
code class='language-default'><code class='language-default'>breakcode>code>，或者你只取了几个
<
code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>next()值就不再需要了），那么生成器函数中剩余的计算将永远不会发生。这避免了不必要的计算开销，特别是在处理复杂或耗时的数据生成逻辑时，能显著提高效率。
-
流式处理能力： 惰性求值让生成器函数非常适合构建数据处理管道。你可以将多个生成器函数串联起来，形成一个数据转换链。每个生成器只负责其特定的转换，并按需将数据传递给下一个生成器。这种模式使得处理大型数据集变得非常高效和灵活，因为它避免了中间结果的完整存储。
// 示例：模拟一个从巨大文件读取并处理数据的生成器 <code class='language-default'>function*code> <code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>(filename) { // 假设这里是一个异步读取文件的API，每次<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>一行yieldconsole.log(`[Generator] 开始读取文件: ${filename}`); let lineNum = 0; while (lineNum < 5) { // 模拟只读5行，实际可能无限 <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> `Line ${++lineNum} from ${filename}`;yieldconsole.log(`[Generator] 暂停，等待下一行...`); }console.log(`[Generator] 文件读取完毕。`); } <code class='language-default'>function*code> <code class='language-default'><code class='language-default'>processDatacode>code>(linesGenerator) {console.log(`[Processor] 开始处理数据...`); <code class='language-default'>forcode> (const line of linesGenerator) { <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> `Processed: ${line.toUpperCase()}`;yieldconsole.log(`[Processor] 暂停，等待下一处理...`); }console.log(`[Processor] 数据处理完毕。`); }const fileLines = <code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>('my_log.txt');const processedLines = <code class='language-default'><code class='language-default'>processDatacode>code>(fileLines); // 消费者只取前3个处理后的结果console.log(processedLines.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>);console.log(processedLines.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>);console.log(processedLines.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>); // 观察输出，你会发现'文件读取完毕'和'数据处理完毕'并没有立即出现， // 并且只有3行数据被实际读取和处理了，即使<code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>理论上可以读更多。
在这个例子中，
<code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>
和
<code class='language-default'><code class='language-default'>processDatacode>code>
都是惰性执行的。只有当
processedLines.<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>.<next()code class='language-default'>valuecode>
被调用时，
<code class='language-default'><code class='language-default'>processDatacode>code>
才会请求
<code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>
的下一行，然后
<code class='language-default'><code class='language-default'><code class='language-default'>readLargeFileLinescode>code>code>
才会去“读取”下一行。这种按需生成和处理的模式，正是惰性求值在优化资源消耗上的强大体现。
在异步编程中，迭代器与生成器模式有哪些进阶应用？
迭代器和生成器模式在异步编程中的应用，可以说是一个演进的过程，从早期的实验性解决方案到如今的语言原生支持，它们极大地提升了异步代码的可读性和可维护性。
一个重要的历史应用是协程（Co-routines）的实现。在ES6引入
<code class='language-default'>code>Promise
和
<code class='language-default'>async/code>await
之前，社区曾探索过如何更好地管理异步操作的顺序和流程。生成器函数因其能够暂停和恢复执行的特性，被用来模拟协程，从而“扁平化”回调地狱。著名的
co库（由TJ Holowaychuk开发）就是利用生成器函数和
<code class='language-default'>code>Promise
来编写同步风格的异步代码的典范。它通过迭代生成器，遇到
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
一个
<code class='language-default'>code>Promise
时就等待
<code class='language-default'>code>Promise
解决，然后将结果
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
回生成器，继续执行。这在当时是一种非常先进的异步流程控制方式。
// 早期co库的简化概念 <code class='language-default'>function*code> asyncFlow() {const1 = <datacode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> fetch('/api/yield1').then(res => res.json());dataconsole.log('Got1:',data1);dataconst2 = <datacode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code> fetch(`/api/yield2?id=${data1.id}`).then(res => res.json());dataconsole.log('Got2:',data2); <datacode class='language-default'>returncode>2; } // 实际dataco库会有一个run函数来驱动这个生成器 // 这里只是展示其思想，它让异步代码看起来像同步
随着JavaScript语言的发展，现在我们有了更直接、更原生的异步迭代器和异步生成器。它们通过
Symbol.asyncIterator和
async <code class='language-default'>function*code>
关键字来定义，并可以通过
<code class='language-default'>forcode>...ofawait
循环来消费。
异步迭代器（Async Iterators） 允许你迭代那些其
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>next()
方法返回
<code class='language-default'>code>Promise
的数据源。这意味着每次获取下一个值可能是一个异步操作。当你在处理网络请求流、数据库查询结果分页、或者实时事件流时，这变得异常有用。
// 示例：一个异步迭代器，模拟分页获取数据 async <code class='language-default'>function*code>(baseUrl) { let page = 1; while (<fetchUserPagescode class='language-default'>truecode>) {const response =fetch(`${baseUrl}/users?page=${page}`);awaitconst=dataresponse.json(); if (await.length === 0) { // 没有更多数据了 <datacode class='language-default'><code class='language-default'>breakcode>code>; } <code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>*yield; // 使用<datacode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>* 委托给yield数组的迭代器，逐个<datacode class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>用户yieldpage++; } } // 消费异步数据流 async function processUsers() {const userStream =('https://api.example.fetchUserPagescom'); // 假设这是一个API letcount = 0; <code class='language-default'>forcode>(awaitconst user of userStream) {console.log(`Processing user: ${user.name}`);count++; if (count >= 5) { // 只处理前5个用户 <code class='language-default'><code class='language-default'>breakcode>code>; } }console.log('Finished processing users.'); } // processUsers(); // 调用以开始异步处理
在这个
fetchUserPages例子中，
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>*yielddata
是一个非常强大的语法。它允许一个生成器将控制权委托给另一个可迭代对象（这里是
data数组），或者另一个生成器。这意味着
fetchUserPages会先
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
出
data数组中的所有用户，然后才会在
data耗尽后继续执行
page++并进行下一次网络请求。这在构建复杂的异步数据管道时，提供了极大的灵活性。
异步生成器（Async Generators） 允许你在生成器函数内部使用
await关键字。这意味着你可以编写一个生成器，它在
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
一个值之前，可以先等待一个
<code class='language-default'>code>Promise
解决。这使得生成异步数据流变得非常自然，比如你可以生成一个包含延迟或网络请求结果的序列。
错误处理在异步迭代器和生成器中也得到了很好的支持。你可以在
async <code class='language-default'>function*code>
内部使用
try...catch块来捕获
await或
<code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'><code class='language-default'>code>code>code>code>code>code>code>code>code>yield
表达式可能抛出的错误。此外，生成器对象还有
throw()方法，允许你从外部向生成器内部注入一个错误，这对于控制流和错误传播非常有用。
总的来说，异步迭代器和生成器模式为JavaScript处理异步数据流提供了一套强大且富有表现力的工具。它们将异步操作的复杂性封装在生成器内部，让外部的消费代码能够以同步迭代的思维模式去处理异步数据，极大地提升了代码的可读性和维护性，是现代JavaScript异步编程中不可或缺的一部分。
datadatadatadatadatadatadatadatadatadatadatadatadatadatadatadatacode class='language-default'>forcode>" target="_blank"><code class='language-default'>forcode> datadatadatadatadatacode class='language-default'><code class='language-default'>breakcode>code>" target="_blank"><code class='language-default'><code class='language-default'>breakcode>code> datadatadatadatadatadatadatadatadatadatadatadatadata大家都在看：
datadatadatadatadatadatadatadatadatadatadatadatadatadatadatadatacode class='language-default'>forcode>" target="_blank"><code class='language-default'>forcode> datadatadatadatadatacode class='language-default'><code class='language-default'>breakcode>code>" target="_blank"><code class='language-default'><code class='language-default'>breakcode>code> datadatadatadatadatadatadatadatadatadatadatadatadata