在.NET反應性框架中實現(xiàn)LINQ
反應性編程和.NET反應性框架并不是新事物。它早已經(jīng)為Cells（一種Common Lisp的數(shù)據(jù)流擴展），和支持高階反應性編程的Python擴展Trellis所應用。在C#中，程序員在指定異步操作指定回調，或事件處理程序的時候使用反應性編程。在異步操作完成或者事件觸發(fā)的時候，就會調用方法并作為對該事件的反應。
在.NET反應性框架中，LINQ to Object使用IEnumerable和IEnumerator兩個接口來迭代數(shù)據(jù)集。枚舉器的MoveNext()方法用于從前一個元素枚舉到下一個元素，而Current屬性則用于檢索個別的元素。這種機制采取廣泛使用的簡潔易懂的“拉（pull）”過程。Erik還發(fā)現(xiàn)IEnumerable有對偶特性：一個是可以從集合中提取數(shù)據(jù)，同時可以把數(shù)據(jù)推進同樣的集合。這意味著另一種反應性編程的方式。
理論上來說，IEnumerable接口可對集合添加對象，但是由于它的阻塞性所以不能在異步操作中進行。那就是為什么該團隊引入了兩個新的接口：IObservable和IObserver。人們可以把IObserver賦給數(shù)據(jù)集并把它作為IObservable訂閱。當一項新的數(shù)據(jù)可用時，就可以通過傳遞IObservable來把它壓進集合，接著再傳給IObserver。微軟展示平臺控件小組的開發(fā)人員Jafar Husain解釋IObserver模式的使用方法如下：
要遍歷IObservable，你需要做的就是執(zhí)行與IEnumerable相反的操作。創(chuàng)建IObserver，把它賦給IObservable，接著IObservable通過調用自身的方法來把數(shù)據(jù)壓進IObserver。在IObservable對Observer調用OnUpdate方法的時候，就相當于IEnumerable方法使用關鍵字yield向IEnumerable傳遞信息。類似地，在IObservable對Observer調用OnCompleted方法的時候，就相當于IEnumerable使用關鍵字break來表示沒有數(shù)據(jù)一樣。
這樣做的好處是什么呢？這種方法在處理事件的時候有著極大的優(yōu)勢。我們可以把IObserver附加到鼠標事件并對這些事件異步記錄到一個集合當中。接著就可以使用LINQ來迭代數(shù)據(jù)，并進行相應的處理。要說明它在處理GUI事件的威力，Rx框架已經(jīng)在Silverlight Toolkit單元測試中使用，并包含源代碼，封裝在System.Reactive.dll中。這也將會包含在.NET 4.0。
軟件架構師和天文物理學家Brian Beckman在視頻采訪Erik Meijer時，證實了IObservable是連續(xù)的Monad，即IEnumerable Monad的對偶性。Erik也介紹了如何通過二元化IEnumerable來構建IObservable 接口。
在.NET反應性框架中實現(xiàn)LINQ就介紹到這里。
【編輯推薦】
