13

我有一个 winform 应用程序，以及一个像这样的 observable 设置：

Form form = new Form();
Label lb = new Label();
form.Controls.Add(lb);

Observable.Interval(TimeSpan.FromSeconds(1))
          .Subscribe(l => lb.Text = l.ToString());

Application.Run(form);

这不起作用，因为l => lb.Text = l.ToString()不会在创建表单的主线程上运行，但我不知道如何让它在这个线程上运行。我假设我应该使用IObservable.SubscribeOnwhich 需要 anIScheduler或 a SynchronizationContext，但我不知道如何获取主线程的同步上下文，并且我能找到的唯一调度程序是 的静态属性，Scheduler例如Scheduler.CurrentThread, Immediate,和NewThread,没有一个奏效。TaskPoolThreadPool

我的 Rx 版本是 1.0.10621。

4

1 回答 1

26

就在我发布问题后，我找到了解决方案：

Form form = new Form();
Label lb = new Label();
form.Controls.Add(lb);

Observable.Interval(TimeSpan.FromSeconds(2))
          .ObserveOn(SynchronizationContext.Current)
          .Subscribe(l => lb.Text = l.ToString());

Application.Run(form);

这个链接很有帮助。两个注意事项：

  • 并非所有线程都有同步上下文，但在线程上创建的第一个表单将为该线程设置同步上下文，因此 UI 线程总是有一个。
  • 正确的方法是ObserveOn，不是SubscribeOn。目前，我对此知之甚少，不知道为什么，所以评论中的任何链接将不胜感激。

编辑：感谢此ObserveOn链接的第一部分，我现在了解更多关于和之间的区别SubscribeOn。简而言之：

  • 在同步上下文上观察的可观察对象将从该上下文调用 IObserver 方法（OnNext和朋友）。在我的示例中，我在主/UI 线程上观察，因此没有出现跨线程异常
  • SubscribeOn稍微复杂一点，所以这里有一个例子： Concat 接受一些 observable 并将它们组合成一个 long observable。一旦 observable 调用OnCompleted，组合后的 observable 将处理该订阅，并订阅下一个 observable。这一切都发生在调用 的线程上OnCompleted，但是订阅由 创建的可观察对象可能会出现一些问题Observable.FromEvent，例如，如果您从 UI 线程之外的另一个线程添加事件处理程序，Silverlight 将抛出，并且 WinForms 和 WPF 将抛出如果您添加来自多个不同线程的事件处理程序。SubscribeOn将让您控制您的可观察对象连接到基础事件的线程。
于 2011-09-14T14:36:56.833 回答