RxJS中queueScheduler与null调度器差异困惑：代码结果不符预期

你遇到的问题核心在于combineLatest的订阅顺序和不同调度器的任务执行时机，而非queueScheduler的“广度优先”逻辑理解错误，下面拆解具体原因：

1. 先明确两个关键前提 #

• combineLatest的触发规则：只有当所有源Observable都至少发射过一次值后，才会在任意源发射新值时，结合所有源的最新值输出。
• combineLatest的订阅顺序：它会依次订阅传入的每个源Observable，先订阅第一个，完成第一个源的订阅逻辑后，再订阅第二个，以此类推。

2. 三种场景的执行流程分析 #

场景1：使用asyncScheduler #

combineLatest([
  scheduled([1, 2], asyncScheduler),
  from([10]),
]).subscribe(console.log);

执行步骤：

1. combineLatest先订阅第一个源：scheduled([1,2], asyncScheduler)会把发射1、2的任务放到宏任务队列（类似setTimeout），不会立即执行。
2. 接着订阅第二个源：from([10])同步发射10，但此时第一个源还没发射任何值，combineLatest不输出。
3. 当前同步执行栈清空后，开始处理宏任务队列：
   • 先执行发射1的任务，此时两个源都有值（1和10），输出[1, 10]。
   • 再执行发射2的任务，结合最新的10，输出[2, 10]。

场景2：使用queueScheduler或默认调度器（from([1,2])） #

// 两种写法结果一致
combineLatest([
  scheduled([1, 2], queueScheduler),
  from([10]),
]).subscribe(console.log);

combineLatest([
  from([1, 2]),
  from([10]),
]).subscribe(console.log);

执行步骤：

1. combineLatest先订阅第一个源：
   • 若用from([1,2])：默认使用同步调度器（null），会在订阅时立即同步依次发射1、2。
   • 若用scheduled([1,2], queueScheduler)：queueScheduler是同步队列调度器，会在当前执行上下文里依次执行发射任务，同样在订阅阶段就把1、2全部发射完毕。
2. 此时第二个源还未被订阅，combineLatest因缺少第二个源的值，不会输出任何内容。
3. 第一个源的所有值发射完成后，combineLatest才订阅第二个源：from([10])同步发射10，此时第一个源的最新值是2，因此只输出[2, 10]。

3. 为什么你对“广度优先”的预期没实现？ #

你看到的“广度优先”描述，通常是指当多个任务被调度到queueScheduler时，会按队列顺序执行，而非嵌套执行。但在这个场景里，queueScheduler的任务执行是在第二个源订阅之前就完成了，根本没机会和第二个源的发射任务形成“广度优先”的并行执行——因为combineLatest是先处理完第一个源的订阅逻辑，才会去订阅第二个源。

如果想让queueScheduler表现出类似async的“分步发射”效果，可以调整源的发射时机，比如给第一个源的每个值加个延迟（用queueScheduler调度延迟任务），或者让两个源的发射任务都进入queueScheduler队列且交错执行，但你的当前代码里，第一个源的所有发射任务都在第二个源订阅前就执行完了，所以结果和同步调度器一致。

内容的提问来源于stack exchange，提问作者Wan ChengCheng