由一個訂單推送想到了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操作的，這個需要特別注意。