C#并发编程经典实例（第2版）

65

第 6 章

System.Reactive

基础

LINQ

这套语言特征使开发人员能够查询序列。最常用的两个

LINQ

提供程序是内置的

LINQ to Objects

（基于

IEnumerable<T>

）以及

LINQ to Entities

（基于

IQueryable<T>

）。还有很

多其他的提供程序可用，它们的结构大体相同。查询是延迟计算的，序列按需来生成值。从

概念上来看，这是拉式模型，即在计算过程中，值项被一次一个地从查询中拉取出来。

System.Reactive

把事件当作陆陆续续传来的数据序列。正因如此，可以把

System.Reactive

视作

LINQ to Events

（基于

IObservable<T>

）。可观察对象和其他

LINQ

提供程序的主要

区别是，

System.Reactive

是推式模型，这意味着查询定义了程序如何响应事件的到来。

System.Reactive

是基于

LINQ

的，而且额外增加了一些强大的新运算符作为扩展方法。

本章会探讨一些更为常用的

System.Reactive

操作。注意，所有的

LINQ

运算符同样可用。对

于类似过滤（

Where

）和投影（

Select

）等的简单操作，从概念上来看，它们的工作方式与在

任何其他

LINQ

提供程序中别无二致。本章不会探讨这些常见的

LINQ

运算符，而会把注意

力集中在

System.Reactive

基于

LINQ

创建的新功能上，尤其是那些处理时间的功能。

若要使用

System.Reactive

，需要在应用程序中安装用于

System.Reactive ...