由一个订单推送想到了ObservableCollection的神奇用法

概述     最近在做taobao的一个卖家应用，需要订阅taobao的订单推送,示例代码如下：  看到上面的OnMessage场景之后，我突然就鬼使神差的在想最近写的一个服务，其中的一个功能是需要定时的轮询一个集合，这样可以方便的把数据取出来，但是轮训对我来说是被迫的，我急迫需要一种机制对一个集合的数据进行监控，比如List，Dictionary等等，这样我就很方便的对数据进行后续处理，而不是我定时的去轮训一个集合，然后我就想到了wpf里面有一个玩法叫做“属性依赖”，然后就想到了今天要说的“ObservableCollection”集合，下面我们就来看看这个集合的玩法。 一：先看玩法首先我对集合进行Add和Remove *** 作，并且给他注册个change事件，然后用工作线程去执行change事件的逻辑，看看给我什么反馈，神奇的效果即刻开始。class Program{static void Main(string[] args){ObservableCollection<string> list = new ObservableCollection<string>() { "1" };list.CollectionChanged += list_CollectionChanged;for (int i = 0; i < 1000; i++){if (i % 3 == 1){list.RemoveAt(0);}else{list.Add(i.ToString());}}Console.WriteLine("全部结束！！！");Console.Read();}static void list_CollectionChanged(object sender, NotifyCollectionChangedEventArgs e){//为了不阻止主线程Add，事件用 “工作线程”处理Task.Factory.StartNew((o) =>{var obj = o as NotifyCollectionChangedEventArgs;switch (obj.Action){case NotifyCollectionChangedAction.Add:Console.WriteLine("当前线程:{0}, *** 作是:{1} 数据:{2}", Thread.CurrentThread.ManagedThreadId, obj.Action.ToString(), obj.NewItems[0]);break;case NotifyCollectionChangedAction.Move:break;case NotifyCollectionChangedAction.Remove:Console.WriteLine("当前线程:{0}, *** 作是:{1} 数据:{2}", Thread.CurrentThread.ManagedThreadId, obj.Action.ToString(), obj.OldItems[0]);break;case NotifyCollectionChangedAction.Replace:break;case NotifyCollectionChangedAction.Reset:break;default:break;}Thread.Sleep(1000);}, e);}}      从表象来看，CollectionChanged 已经完全的监控到了集合的各个动作，包括Add，Remove，很显然，这比我去轮训数据好多了，不过用的话，谁都会用，关键是要看看怎么实现的，下面我们来剖析下。 二：简单分析下源码首先我们会发现，ObservableCollection继承了一个Collection并且实现了一个“属性通知”和“集合通知”的两个接口INotifyCollectionChanged, INotifyPropertyChanged)。 然后我们发现Add方法是由父类提供，然后调用ObservableCollection中提供了InsertItem方法，如下图。  可以看到，在我们上层的Add方法中，其实调用的是InsertItem方法，并且在最后我们看到了一个核心方法OnCollectionChanged，是不是很开心。。。。下面跟着我一起去看看 最终我们开心的看到了这个类的触发机制，只不过是在Add/Remove方法的最后面做了一个事件触发的方法，同时我们也看到了，这是一个同步 *** 作，这就意味着，默认情况下，我的CollectionChanged逻辑是会阻止上层的Add *** 作的，这个需要特别注意。 

　　　　

     最近在做taobao的一个卖家应用，需要订阅taobao的订单推送,示例代码如下：

看到上面的OnMessage场景之后，我突然就鬼使神差的在想最近写的一个服务，其中的一个功能是需要定时的轮询一个集合，这样可以方便的把数据取出来，但是

轮训对我来说是被迫的，我急迫需要一种机制对一个集合的数据进行监控，比如List，Dictionary等等，这样我就很方便的对数据进行后续处理，而不是我定时的去轮

训一个集合，然后我就想到了wpf里面有一个玩法叫做“属性依赖”，然后就想到了今天要说的“ObservableCollection”集合，下面我们就来看看这个集合的玩法。

　　首先我对集合进行Add和Remove *** 作，并且给他注册个change事件，然后用工作线程去执行change事件的逻辑，看看给我什么反馈，神奇的效果即刻开始。

Main(<> List = ObservableCollection<>() { <a href="https://m.jb51.cc/tag/List/" target="_blank" >List</a>.C<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChanged </span>+=<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; <a href="https://m.jb51.cc/tag/List/" target="_blank" >List</a>_C<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChanged; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;for</span> (<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;int</span> i = <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;0</span>; i < <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;1000</span>; i++<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;) { </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;if</span> (i % <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;3</span> == <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;1</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;) { <a href="https://m.jb51.cc/tag/List/" target="_blank" >List</a>.RemoveAt(</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;0</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;); } </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;else</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; { <a href="https://m.jb51.cc/tag/List/" target="_blank" >List</a>.Add(i.ToString()); } } Cons<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>e.Write<a href="https://m.jb51.cc/tag/li/" target="_blank" >li</a>ne(</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;"</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;全部结束！！！</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;"</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;); Cons<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>e.Read(); } </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;static</span> <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;vo<a href="https://m.jb51.cc/tag/ID/" target="_blank" >ID</a></span> <a href="https://m.jb51.cc/tag/List/" target="_blank" >List</a>_C<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChanged(<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;object</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; sender,NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedEventArgs e) { </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #008000;"&gt;//</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #008000;"&gt;为了不阻止主线程Add，事件用 “<a href="https://m.jb51.cc/tag/gongzuo/" target="_blank" >工作</a>线程”处理</span> Task.Factory.StartNew((o) =><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; { </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;var</span> obj = o <span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;as</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedEventArgs; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;switch</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; (obj.Action) { </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;case</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedAction.Add: Cons<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>e.Write<a href="https://m.jb51.cc/tag/li/" target="_blank" >li</a>ne(</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;"</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;当前线程:{0}, *** 作是:{1} 数据:{2}</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;"</span>,Thread.CurrentThread.ManagedThread<a href="https://m.jb51.cc/tag/ID/" target="_blank" >ID</a>,obj.Action.ToString(),obj.NewItems[<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;0</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;]); </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;case</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedAction.Move: </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;case</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedAction.Remove: Cons<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>e.Write<a href="https://m.jb51.cc/tag/li/" target="_blank" >li</a>ne(</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;"</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800000;"&gt;当前线程:{0},obj.<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>dItems[<span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;0</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;]); </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;case</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedAction.Replace: </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;case</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt; NotifyC<a href="https://m.jb51.cc/tag/ol/" target="_blank" >ol</a>lectionChangedAction.<a href="https://m.jb51.cc/tag/reset/" target="_blank" >reset</a>: </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;defa<a href="https://m.jb51.cc/tag/ul/" target="_blank" >ul</a>t</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;: </span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #0000ff;"&gt;break</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;; } Thread.Sleep(</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #800080;"&gt;1000</span><span https://m.jb51.cc/tag/color/" target="_blank" >color</a>: #000000;"&gt;); },e); }}</span></pre>

     从表象来看，CollectionChanged 已经完全的监控到了集合的各个动作，包括Add，Remove，很显然，这比我去轮训数据好多了，不过用的话，谁都会用，

关键是要看看怎么实现的，下面我们来剖析下。

　　首先我们会发现，ObservableCollection继承了一个Collection并且实现了一个“属性通知”和“集合通知”的两个接口INotifyCollectionChanged,

 INotifyPropertyChanged)。

然后我们发现Add方法是由父类提供，然后调用ObservableCollection中提供了InsertItem方法，如下图。

可以看到，在我们上层的Add方法中，其实调用的是InsertItem方法，并且在最后我们看到了一个核心方法OnCollectionChanged，是不是很开心。。。。

下面跟着我一起去看看

最终我们开心的看到了这个类的触发机制，只不过是在Add/Remove方法的最后面做了一个事件触发的方法，同时我们也看到了，

总结

以上是内存溢出为你收集整理的由一个订单推送想到了ObservableCollection的神奇用法全部内容，希望文章能够帮你解决由一个订单推送想到了ObservableCollection的神奇用法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/langs/1264098.html