最近在做taobao的一個賣家應用,需要訂閱taobao的訂單推送,示例代碼如下:
一:先看玩法
首先我對集合進行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操作的,這個需要特別注意。