RxJava：doOnTerminate与doAfterTerminate对比及相关疑问

先搞懂最核心的区别：执行时机 #

这俩的本质差异全在什么时候跑：

• doOnTerminate：Observable要终止（不管是正常onComplete还是报错onError）的前一刻执行。也就是说，它会抢在终止信号传递给下游观察者之前先运行。
  给你看个实际代码例子：

  Observable.just("hello rxjava")
      .doOnTerminate(() -> System.out.println("我是doOnTerminate，先跑一步！"))
      .subscribe(
          content -> System.out.println("收到内容：" + content),
          error -> System.out.println("出错了：" + error),
          () -> System.out.println("下游收到onComplete啦")
      );
  

  输出顺序会是：

  收到内容：hello rxjava
  我是doOnTerminate，先跑一步！
  下游收到onComplete啦
  

• doAfterTerminate：Observable的终止信号已经完全传递给下游观察者之后才执行。相当于整个序列彻底结束后的"最后一步"。
  把上面的代码换成doAfterTerminate，输出就变了：

  Observable.just("hello rxjava")
      .doAfterTerminate(() -> System.out.println("我是doAfterTerminate，等大家都干完我再跑！"))
      .subscribe(
          content -> System.out.println("收到内容：" + content),
          error -> System.out.println("出错了：" + error),
          () -> System.out.println("下游收到onComplete啦")
      );
  

  输出顺序：

  收到内容：hello rxjava
  下游收到onComplete啦
  我是doAfterTerminate，等大家都干完我再跑！
  

既然有doOnTerminate，为啥还要doAfterTerminate？ #

这就像你下班：doOnTerminate是你关电脑前先整理桌面，doAfterTerminate是你锁好办公室门再走。它的存在价值主要在这几个场景：

1. 等下游收尾完再做全局清理：如果下游观察者里有自己的资源释放、状态更新逻辑，你肯定希望这些操作全部完成后，再执行全局的收尾（比如关闭数据库连接、上报整个接口请求的结束统计）。doAfterTerminate就能保证这点，因为它是等下游的onComplete/onError都执行完才触发。
2. 不干扰终止信号的传递：要是doOnTerminate里的代码不小心抛了异常，虽然RxJava会处理，但难保不会影响原本的终止信号传递（比如把原本的正常完成变成错误？虽然概率低，但风险存在）。而doAfterTerminate是在终止信号已经发完后才跑，它的异常不会影响下游收到的终止事件，更安全。
3. 真正的"最终收尾"：有些操作就是要等整个序列彻底结束才能做，比如记录整个请求的总耗时（得等下游处理完所有结果再算）、释放那些只有所有观察者都处理完才能释放的共享资源，这时候doAfterTerminate就是唯一合适的选择。

为啥官方文档早期只列doOnTerminate？ #

这个我也注意到过，主要是历史和文档迭代的问题：

1. API迭代顺序：doAfterTerminate是RxJava 1.1.x版本左右才新增的，早期的基础文档是基于更早的版本写的，那时候还没有这个操作符，所以只列了doOnTerminate。
2. 核心vs补充的定位：doOnTerminate是更基础的终止回调，覆盖大部分通用场景；而doAfterTerminate是针对特定细分场景的补充功能。官方可能觉得入门文档优先放核心操作符，进阶的补充操作符放在详细API参考里。
3. 文档维护滞后：开源项目的文档更新经常跟不上代码迭代，尤其是这种补充性的小操作符，可能不会第一时间同步到入门级文档里。不过现在新版本的RxJava官方文档已经把两者都列出来了，你去看最新的API文档就能找到。

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