ReactiveX/RxJava
7 articles
前置知识
- ›对响应式编程基本概念有所了解（Observable、subscribe、operators）
- ›了解 Java 模块系统基础（module-info.java）
01
深入 RxJava：架构概览与 877 个源文件的导航指南
全面梳理 RxJava 代码库，涵盖项目结构、公共/内部 API 边界、5+2 核心响应式类型、命名规范以及构建基础设施。
02
订阅链：每个 RxJava 操作符的实际运作机制
完整追踪从用户调用到插件钩子再到 subscribeActual() 的订阅流程，以 FlowableMap 为典型示例，深入解析操作符的装饰器模式。
03
引擎室：Drain 循环、队列融合与无锁并发
深入探讨 WIP drain 循环模式、QueueFuseable 算子融合协议、无锁 SPSC 队列以及 ConditionalSubscriber 优化——这些机制共同构成了 RxJava 高性能的核心。
04
深入解析调度器：线程池、虚拟线程与时间控制
从 Scheduler/Worker 基类出发，逐层剖析 RxJava 的线程抽象，涵盖 ComputationScheduler、CachedScheduler、DeferredExecutorScheduler（虚拟线程）以及 TestScheduler。
05
背压：Flowable 如何防止高速生产者压垮慢速消费者
深入讲解 request(n) 协议、BackpressureHelper 的 CAS 算术、五种 BackpressureStrategy 选项、prefetch/limit 模式，以及 FlowableFlatMap 的多源请求计数机制。
06
RxJava 4.x：Streamable、虚拟线程与响应式 Java 的未来
深入介绍 Streamable<T> 异步枚举、用于命令式虚拟线程编程的 VirtualGenerator/VirtualEmitter、密封类型、记录类，以及向 java.util.concurrent.Flow 的迁移。
07
守护 54,000 行代码的质量：RxJava 的测试与验证体系
深入解析 TestSubscriber、TestScheduler、24 个验证器元测试、Reactive Streams TCK 合规测试、JMH 基准测试，以及将它们串联起来的 CI 流水线。