反应式扩展 ControlScheduler

Question

我正在使用 ReactiveExtensions 事件处理程序来处理我的应用程序事件，我还使用 ControlScheduler 来在 ui 线程上运行处理程序。但是，尽管使用了 ControlScheduler，但最近我得到了 Cross Thread 异常，我不知道是什么问题

代码：

Observable.FromEventPattern<string>(cc, "UiAlertMessage", new ControlScheduler(this)).Subscribe(_ =>
{
    AlertControl.Show(this, Language.Title, _.EventArgs.UppercaseFirst());
});

new ControlScheduler(this) 不是应该在 UI 线程上运行代码，所以我没有得到跨线程异常吗？

Answer 1

你应该这样做

Observable.FromEventPattern<string>(cc, "UiAlertMessage")
    .ObserveOn(this)
    .Subscribe(_ =>
    {
        AlertControl.Show(this, Language.Title, _.EventArgs.UppercaseFirst());
    });

这是标准的调度方式，用于与具体控件相关的调度器。像您在控件上完成 subscribes 而不是 observes 那样传递控制计划。有关ObserverOn 和SubscribeOn 之间的区别，请参阅this answer

注意ObserveOn 的实现来自System..Reactive.Windows.Forms 程序集。

public static IObservable<TSource> ObserveOn<TSource>
(this IObservable<TSource> source, Control control)
{
  if (source == null)
    throw new ArgumentNullException("source");
  if (control == null)
    throw new ArgumentNullException("control");
  else
    return Synchronization.ObserveOn<TSource>(source, (IScheduler) new ControlScheduler(control));
}