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

72

｜

第

6

章

49: Saw 93 items.

50: Saw 98 items.

51: Saw 39 items.

52: Saw 0 items.

53: Saw 4 items.

54: Saw 0 items.

55: Saw 58 items.

讨论

利用

Buffer

和

Window

这样的工具，可以将输入塑造成期望看到的样子。另一个实用的技

巧是节流，参见

6.4

节。

Buffer

和

Window

都有其他的重载，可以在更高级的场景中使用。带有

skip

参数和

timeShift

参数的重载既可以创建与其他分组重叠的分组，也可以在组与组之间跳过元素。还有一些重

载接受委托，可用于动态定义分组的边界。

参阅

6.1

节探讨从事件中创建序列。

6.4

节探讨如何节流事件流。

6.4

　通过节流和采样控制事件流

问题

在编写响应式代码时，事件传入过快是常见的问题，但是高速运行的事件流会使程序不堪

重负。

解决方案

为了应付事件数据的洪流，

System.Reactive

提供了专门的运算符。

Throttle

（节流）和

Sample

（采样）提供了两种“驯化”高速输入事件的途径。

Throttle

运算符创建一个滑动的超时窗口。当事件到达时，它会重置超时窗口。当超时窗

口过期时，它会发布最后一个到达窗口的事件值。

下面的示例监听鼠标移动，当且仅当鼠标静止整整

1

秒后，才通过

Throttle

运算符汇报

更新：

private void

Button_Click(

object

sender, RoutedEventArgs e)

{

System.Reactive ...