C# Singleton UI 线程问题

Question

我正在使用其他人编写的获取市场数据的服务。它连接到他们的服务器，你向它发送一个符号，它会发回数据。好吧，我正在尝试使用它打开多个视图，以便您可以获得多个交易品种的市场数据。完成此操作的方法是，我的 ViewModel 订阅单例事件 IncomingMessage，如果消息包含 ViewModel 的符号，则会将其放入 ObservableCollection 中。这就是问题所在。

如何将活动消息安全地添加到我的收藏中？

[编辑] 我相信抛出异常是因为我的 ObservableCollection 绑定到我视图上的 DataGrid。

Answer 1

您需要将对 Add 方法的调用封送至 UI 线程。在 Prism 中，这通常是通过事件聚合器完成的，但如果您不使用 prism：

假设您有某种类型 Tick 代表您的市场数据，并且数据事件只是一个 System .Action：

dataSource.IncomingMessage += (tick) => Application.Current.Dispatcher.Invoke(new Action<Tick>(AddTheTick), tick);

或者，简单地说

dataSource.IncomingMessage += (tick) => Application.Current.Dispatcher.Invoke(new Action<Tick>(myObservableCollection.Add), tick);

Answer 2

ObservableCollection 通常无法从后台线程更新。您需要使用 Dispatcher.Invoke() 或 Dispatcher.BeginInvoke() 来确保数据添加到集合所属的线程上。

Application.Current.Dispatcher.Invoke((Action)(() => myObservableCollection.Add(value)));

这是一项非常常见的任务，值得创建一个扩展方法来为您处理这个问题：

static class ObservableCollectionExtensions
{
    internal static void InvokeAdd<T>(this ObservableCollection<T> self, T item)
    {
        Application.Current.Dispatcher.Invoke((Action<T>)self.Add, item);
    }

    internal static void BeginInvokeAdd<T>(this ObservableCollection<T> self, T item)
    {
        Application.Current.Dispatcher.BeginInvoke(new Action<T>(self.Add), item);
    }
}

这样您就可以安全地进行几次击键并输入以下内容：

myObservableCollection.InvokeAdd(value);