Reactive Extensions中Observable的工作线程疑问咨询

问题解答 #

Cold Observable 相关疑问 #

• 生成数字的线程：Observable.Interval默认使用.NET的线程池（ThreadPool）线程来调度定时任务，数字就是在这些后台线程上生成的。
• 每个订阅是否创建新线程：是的！Cold Observable的特性就是「订阅即激活」——每新增一个订阅，都会启动一个新的线程池线程，同时创建一个完全独立的数据流实例。
• 数字独立是否说明各订阅有独立源：完全正确！你看代码里Observer1运行5秒后Observer2才订阅，Observer2是从0开始输出的，和Observer1的数字序列完全不重叠，这直接证明了每个订阅都对应一个独立的源，彼此之间没有共享数据流。

Hot Observable 相关疑问 #

没错！当我们用Publish将Cold Observable转为Hot（IConnectableObservable）后，调用Connect()才会真正启动源的数据流——此时只会有一个线程池线程负责生成数字，所有订阅者都会共享这同一个数据流（所以Observer2订阅后会直接拿到当前正在生成的数字，而不是从0开始）。而主线程在最后调用Console.ReadKey()，确实处于等待用户输入的状态，不会干扰后台生成数字的线程。

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