我在哪里可以获得线程安全的 CollectionView？

Question

在后台线程上更新业务对象集合时，我收到以下错误消息：

这种类型的 CollectionView 不支持从与 Dispatcher 线程不同的线程更改其 SourceCollection。

好吧，这是有道理的。但它也引出了一个问题，什么版本的 CollectionView 确实支持多线程以及如何让我的对象使用它？

Answer 1

使用：

System.Windows.Application.Current.Dispatcher.Invoke(
    System.Windows.Threading.DispatcherPriority.Normal,
    (Action)delegate() 
    {
         // Your Action Code
    });

Answer 2

以下是 Jonathan 发现的实施改进。首先，它在与其关联的调度程序上运行每个事件处理程序，而不是假设它们都在同一个 (UI) 调度程序上。其次，它使用 BeginInvoke 允许在我们等待调度程序可用时继续处理。在后台线程进行大量更新并在每个更新之间进行处理的情况下，这使得解决方案速度更快。也许更重要的是，它克服了等待 Invoke 时阻塞引起的问题（例如，在将 WCF 与 ConcurrencyMode.Single 一起使用时可能会发生死锁）。

public class MTObservableCollection<T> : ObservableCollection<T>
{
    public override event NotifyCollectionChangedEventHandler CollectionChanged;
    protected override void OnCollectionChanged(NotifyCollectionChangedEventArgs e)
    {
        NotifyCollectionChangedEventHandler CollectionChanged = this.CollectionChanged;
        if (CollectionChanged != null)
            foreach (NotifyCollectionChangedEventHandler nh in CollectionChanged.GetInvocationList())
            {
                DispatcherObject dispObj = nh.Target as DispatcherObject;
                if (dispObj != null)
                {
                    Dispatcher dispatcher = dispObj.Dispatcher;
                    if (dispatcher != null && !dispatcher.CheckAccess())
                    {
                        dispatcher.BeginInvoke(
                            (Action)(() => nh.Invoke(this,
                                new NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Reset))),
                            DispatcherPriority.DataBind);
                        continue;
                    }
                }
                nh.Invoke(this, e);
            }
    }
}

因为我们使用的是 BeginInvoke，所以通知的更改可能会在调用处理程序之前被撤消。这通常会导致“索引超出范围”。当根据列表的新（更改）状态检查事件参数时抛出异常。为了避免这种情况，所有延迟事件都被替换为重置事件。在某些情况下，这可能会导致过度重绘。

Answer 3

Bea Stollnitz 的这篇文章解释了错误消息以及原因它的措辞就是这样。

编辑：来自 Bea 的博客

不幸的是，这段代码会导致异常：“NotSupportedException – 这种类型的 CollectionView 不支持从与 Dispatcher 线程不同的线程更改其 SourceCollection。”我知道这个错误消息会让人们认为，如果他们使用的 CollectionView 不支持跨线程更改，那么他们必须找到支持跨线程更改的集合视图。嗯，这个错误消息有点误导：我们提供的开箱即用的 CollectionView 都不支持跨线程集合更改。不，不幸的是，我们目前无法修复错误消息，我们已经被锁定了。

Answer 4

找到了一个。

public class MTObservableCollection<T> : ObservableCollection<T>
{
   public override event NotifyCollectionChangedEventHandler CollectionChanged;
   protected override void OnCollectionChanged(NotifyCollectionChangedEventArgs e)
   {
      var eh = CollectionChanged;
      if (eh != null)
      {
         Dispatcher dispatcher = (from NotifyCollectionChangedEventHandler nh in eh.GetInvocationList()
                 let dpo = nh.Target as DispatcherObject
                 where dpo != null
                 select dpo.Dispatcher).FirstOrDefault();

        if (dispatcher != null && dispatcher.CheckAccess() == false)
        {
           dispatcher.Invoke(DispatcherPriority.DataBind, (Action)(() => OnCollectionChanged(e)));
        }
        else
        {
           foreach (NotifyCollectionChangedEventHandler nh in eh.GetInvocationList())
              nh.Invoke(this, e);
        }
     }
  }
}

http://www.julmar.com/blog/mark/2009 /04/01/AddingToAnObservableCollectionFromABackgroundThread.aspx

Answer 5

您还可以查看：BindingOperations.EnableCollectionSynchronization。

请参阅升级到 .NET 4.5 : ItemsControl 与其项目源不一致

Answer 6

抱歉，无法添加评论，但这一切都是错误的。

ObservableCollection 不是线程安全的。不仅因为这个调度程序问题，而且它根本不是线程安全的（来自msdn）：

此类型的任何公共静态（在 Visual Basic 中为共享）成员都是线程安全的。不保证任何实例成员都是线程安全的。

看这里 http://msdn.microsoft.com /en-us/library/ms668604(v=vs.110).aspx

使用“重置”操作调用 BeginInvoke 时也存在问题。 “重置”是处理程序应该查看集合本身的唯一操作。如果您开始调用“重置”，然后立即开始调用几个“添加”操作，则处理程序将接受具有已更新集合的“重置”，而下一个“添加”将造成混乱。

这是我的有效实现。实际上，我正在考虑完全删除 BeginInvoke：

快速执行和线程安全的可观察集合

Answer 7

您可以让 wpf 通过启用集合同步来管理对集合的跨线程更改，如下所示：

BindingOperations.EnableCollectionSynchronization(collection, syncLock);
listBox.ItemsSource = collection;

这告诉 WPF 可以在 UI 线程之外修改集合，因此它知道必须将任何 UI 更改封送回适当的线程。

如果您没有锁对象，还有一个重载可以提供同步回调。

Answer 8

如果您想定期更新 WPF UI 控件并同时使用 UI，则可以使用 DispatcherTimer。

XAML

<Grid>
        <DataGrid AutoGenerateColumns="True" Height="200" HorizontalAlignment="Left" Name="dgDownloads" VerticalAlignment="Top" Width="548" />
        <Label Content="" Height="28" HorizontalAlignment="Left" Margin="0,221,0,0" Name="lblFileCouner" VerticalAlignment="Top" Width="173" />
</Grid>

C#

 public partial class DownloadStats : Window
    {
        private MainWindow _parent;

        DispatcherTimer timer = new DispatcherTimer();

        ObservableCollection<FileView> fileViewList = new ObservableCollection<FileView>();

        public DownloadStats(MainWindow parent)
        {
            InitializeComponent();

            _parent = parent;
            Owner = parent;

            timer.Interval = new TimeSpan(0, 0, 1);
            timer.Tick += new EventHandler(timer_Tick);
            timer.Start();
        }

        void timer_Tick(object sender, EventArgs e)
        {
            dgDownloads.ItemsSource = null;
            fileViewList.Clear();

            if (_parent.contentManagerWorkArea.Count > 0)
            {
                foreach (var item in _parent.contentManagerWorkArea)
                {
                    FileView nf = item.Value.FileView;

                    fileViewList.Add(nf);
                }
            }

            if (fileViewList.Count > 0)
            {
                lblFileCouner.Content = fileViewList.Count;
                dgDownloads.ItemsSource = fileViewList;
            }
        }   

    }

Answer 9

试试这个：

this.Dispatcher.Invoke(DispatcherPriority.Background, new Action(
() =>
{

 //Code

}));

Answer 10

都没有，只需使用 Dispatcher.BeginInvoke

Answer 11

这是我在谷歌搜索和轻微修改后制作的 VB 版本。对我有用。

  Imports System.Collections.ObjectModel
  Imports System.Collections.Specialized
  Imports System.ComponentModel
  Imports System.Reflection
  Imports System.Windows.Threading

  'from: http://stackoverflow.com/questions/2137769/where-do-i-get-a-thread-safe-collectionview
  Public Class ThreadSafeObservableCollection(Of T)
    Inherits ObservableCollection(Of T)

    'from: http://geekswithblogs.net/NewThingsILearned/archive/2008/01/16/listcollectionviewcollectionview-doesnt-support-notifycollectionchanged-with-multiple-items.aspx
    Protected Overrides Sub OnCollectionChanged(ByVal e As System.Collections.Specialized.NotifyCollectionChangedEventArgs)
      Dim doit As Boolean = False

      doit = (e.NewItems IsNot Nothing) AndAlso (e.NewItems.Count > 0)
      doit = doit OrElse ((e.OldItems IsNot Nothing) AndAlso (e.OldItems.Count > 0))

      If (doit) Then
        Dim handler As NotifyCollectionChangedEventHandler = GetType(ObservableCollection(Of T)).GetField("CollectionChanged", BindingFlags.Instance Or BindingFlags.NonPublic).GetValue(Me)
        If (handler Is Nothing) Then
          Return
        End If

        For Each invocation As NotifyCollectionChangedEventHandler In handler.GetInvocationList
          Dim obj As DispatcherObject = invocation.Target

          If (obj IsNot Nothing) Then
            Dim disp As Dispatcher = obj.Dispatcher
            If (disp IsNot Nothing AndAlso Not (disp.CheckAccess())) Then
              disp.BeginInvoke(
                Sub()
                  invocation.Invoke(Me, New NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Reset))
                End Sub, DispatcherPriority.DataBind)
              Continue For
            End If
          End If

          invocation.Invoke(Me, e)
        Next
      End If
    End Sub
  End Class

Answer 12

VB版本中的小错误。只需替换：

Dim obj As DispatcherObject = invocation.Target

由

Dim obj As DispatcherObject = TryCast(invocation.Target, DispatcherObject)