重构代码时移除SubscribeOn/ObserveOn后ViewModel绑定为何停止更新？

这是个非常典型的Rx线程调度踩坑场景，我来帮你理清楚背后的逻辑，以及怎么解决你的问题！

先搞懂SubscribeOn和ObserveOn到底干了啥 #

这两个操作符是Rx线程调度的核心，作用完全不同：

• SubscribeOn(ThreadPoolScheduler.Instance)：指定**订阅过程（包括Observable的初始化、上游事件的产生逻辑）**运行在ThreadPool线程。如果没加这个，订阅逻辑会默认跑在你调用Subscribe()的那个线程——如果是UI线程，上游的阻塞/耗时操作会直接卡死界面。
• ObserveOn(Application.Current.Dispatcher)：指定下游订阅者接收事件的线程为UI主线程（Dispatcher线程）。WPF、WinUI这类UI框架有严格的线程模型：UI元素和绑定属性的更新必须在主线程执行，非主线程的更新不会被UI框架识别，甚至会抛出异常。

为什么去掉这两行后，第二个订阅就失效了？ #

你的问题核心出在线程不匹配：

1. 当你去掉SubscribeOn，如果原来的Observable.Create里的逻辑是耗时/阻塞操作，订阅会跑到UI线程执行，不仅卡UI，还可能导致后续WhenRenderProgress的发射线程混乱；
2. 更关键的是ObserveOn的缺失：你的WhenRenderProgress（应该是个Subject）大概率是在后台线程发射进度值的（比如渲染工作在ThreadPool跑），没有ObserveOn的话，ViewModel的订阅会在后台线程接收值，然后更新绑定属性——这时候UI框架根本不会处理这个更新，因为它不是在主线程发生的，所以你看不到界面变化。

Subject本身不会自动切换线程，它在哪条线程调用OnNext()，订阅者就会在哪条线程收到事件，这是关键！

移除Observable.Create的正确姿势 #

如果你的目标是去掉Observable.Create的包装，记住两个核心原则：

1. 上游发射逻辑尽量放在后台线程：避免阻塞UI，比如用Task.Run或者Rx的SubscribeOn来调度耗时的渲染工作；
2. ViewModel的订阅必须强制切换到UI线程：也就是ObserveOn(Application.Current.Dispatcher)绝对不能丢（或者用RxApp.MainThreadScheduler这类跨平台的调度器）。

举个简化的正确示例：

// 假设你的RendererService里的渲染逻辑是后台线程跑的
public class RendererService
{
    private readonly Subject<int> _whenRenderProgress = new Subject<int>();
    public IObservable<int> WhenRenderProgress => _whenRenderProgress;

    public async Task StartRendering()
    {
        // 用Task.Run把渲染逻辑放到后台线程
        await Task.Run(() =>
        {
            for (int i = 0; i <= 100; i++)
            {
                // 这里在后台线程发射值
                _whenRenderProgress.OnNext(i);
                Thread.Sleep(50); // 模拟渲染耗时
            }
            _whenRenderProgress.OnCompleted();
        });
    }
}

// ViewModel里的订阅
public class YourViewModel : INotifyPropertyChanged
{
    private int _renderProgress;
    public int RenderProgress 
    { 
        get => _renderProgress; 
        set 
        {
            _renderProgress = value;
            OnPropertyChanged(nameof(RenderProgress));
        }
    }

    public YourViewModel(RendererService rendererService)
    {
        rendererService.WhenRenderProgress
            // 必须保留这一行，把接收事件切换到UI线程
            .ObserveOn(Application.Current.Dispatcher)
            .Subscribe(progress =>
            {
                RenderProgress = progress; // 现在是在UI线程更新，绑定会生效
            });
    }

    public event PropertyChangedEventHandler PropertyChanged;
    protected void OnPropertyChanged(string propertyName)
    {
        PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
    }
}

额外排查点 #

• 确认你的ViewModel属性已经正确实现了INotifyPropertyChanged——这是绑定更新的基础，虽然你原来的代码能工作，但重构时可能不小心破坏了；
• 检查WhenRenderProgress的订阅有没有被提前Dispose（比如用了IDisposable但没正确保留引用），如果订阅被取消了，自然收不到事件。

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