使用 ToObservable 在另一个线程上执行方法

Question

我在 WPF 应用程序的非 UI 线程上运行方法（基于 ToObservable）时遇到问题。

例如我有这个方法：

    public IObservable<ViewModel> Get()
    {
        IEnumerable<ViewModel> vms = _repository.Get();

        Thread.Sleep(2000);

        return vms.ToObservable();
    }

我在 ViewModel 中使用这个方法：

  manager.Get()
         .ObserveOnDispatcher()
         .SubscribeOn(new NewThreadScheduler())
         .Subscribe(result =>
                    {
                        Data.Add(result);
                    });

问题是 Get 方法在 UI/Main 线程上执行，但我需要在非 UI 线程上运行此方法。

Answer 1

我建议在Observable.Start 内部调用manager.Get()，然后只需执行.Merge() 即可将IObservable<IObservable<ViewModel>> 带回IObservable<ViewModel>。

试试这个：

Observable
    .Start(() => manager.Get(), Scheduler.Default)
    .Merge()
    .ObserveOnDispatcher()
    .SubscribeOn(new NewThreadScheduler())
    .Subscribe(result =>
    {
        Data.Add(result);
    });

.SubscribeOn(new NewThreadScheduler()) 可能不是必需的。

Answer 2

你的想法是对的。但是，为了有效地使用ObserveOn 和SubscribeOn 运算符，您需要有一个可观察的源。在您的示例中，您似乎没有。一旦你得到它，你可以这样做：

IObservable<TAnything> source;

source
    .ObserveOn(Scheduler.ThreadPool)
    .SelectMany(_ => Get())
    .ObserveOn(DispatcherScheduler.Instance)
    .Subscribe(result =>
    {
        Data.Add(result);
    });

在您的情况下，source 很可能是通过单击按钮或其他事件生成的 observable。

ObserveOn 为给定的调度程序调度它后面的代码。因此，在我们的例子中，第一个 ObserveOn 调用使后面的代码发生在 ThreadPool（非 UI）上。第二个ObserveOn 使代码发生在调度程序（UI）上。

SubscribeOn 使订阅时间代码发生在给定的调度程序上。由于您的代码示例在订阅时没有发生任何有趣的事情，因此删除它是有意义的。