使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

牛刀小试:使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

我之前有一篇文章介绍到了Reactive Extension这个组件,请参考下面的文章,其中有一些基本的概念和相关的链接

牛刀小试:使用Reactive Extensions(Rx),一行代码实现多线程任务执行规定时间后自动停止

Rx 目前还没有直接整合到.NET Framework 中,仍然是作为单独的组件存在。至于以后会不会,谁知道呢?我个人希望是可以整合进去。

不管怎么样,我今天还是以实例来讲解这个组件的使用,如果以后有更多有意思的场景,我也会用文章分享出来。

我们要解决的问题

在.NET应用程序开发期间,我们会大量地使用到事件,而且很多事件可能会不止一次地发生,例如TextChanged事件,KeyPress事件,MouseDown事件等等。

由于这些事件会多次发生,在某些场景下,如果每次都进行响应可能有负面的一些问题,例如性能问题。一个典型的案例是:假如我们需要根据TextChanged的事件去调用一个外部的服务,我们知道用户可以在一个很短的时间内(例如1秒内)快速输入很多的字符,同时还可能会删除字符,该事件会在每次发生更改的时候触发,如果按照传统的做法,每次都去调用服务,显然是不合适的,这样会有很多的服务请求。所以,我们可能希望,在某个时间范围内(例如1秒),只触发一次。

为了做这个演示,我做了如下的一个界面(WPF)

<Window x:Class="WpfApplicationSample.MainWindow"
xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
Title="MainWindow"
Height="350"
Width="525">
<StackPanel>
<TextBox Name="txtInput"
TextChanged="txtInput_TextChanged"></TextBox> <RichTextBox Name="txtOutput"> </RichTextBox> </StackPanel>
</Window>

后台代码我简单地做了一个处理(我并没有真的去调用服务,而是做一个结果打印)

using System.Windows;
using System.Windows.Controls; namespace WpfApplicationSample
{
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
public MainWindow()
{
InitializeComponent();
} private void txtInput_TextChanged(object sender, TextChangedEventArgs e)
{
txtOutput.AppendText(txtInput.Text+"\r");
}
}
}

运行起来可以看到如下的效果

使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

传统的方案

针对这样的一种需求,我们按照传统的思路该如何实现呢?说实在的,很难做到。这里面有一个比较复杂的逻辑,也就是说,当一个事件发生了,我们不能马上处理,而是要等待一点时间看看(例如1秒),如果还有新的事件发生(可能会多个),则以1秒内最后那个事件为准。但是,这里还有一个例外情况,如果在1秒内没有其他事件发生,则这个唯一的事件就要被处理。

大家可以自己尝试想想看,要做到这样的逻辑判断实在不那么容易。

使用Rx的方案

而使用Rx的方案,则相对来说很简单,或者可以说是很直白。

首先,我们可以安装Reactive Extensions

使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

然后,我们通过如下的方式来监听这个事件,而不是在xaml中直接定义。

using System;
using System.Reactive.Linq;
using System.Windows;
using System.Windows.Controls; namespace WpfApplicationSample
{
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
public MainWindow()
{
InitializeComponent(); Loaded += MainWindow_Loaded;
} void MainWindow_Loaded(object sender, RoutedEventArgs e)
{
Observable.FromEventPattern<TextChangedEventArgs>(this.txtInput, "TextChanged").Throttle(TimeSpan.FromSeconds(1)).Subscribe(x =>
this.Dispatcher.Invoke(() =>
{
txtOutput.AppendText(txtInput.Text + "\r");
}));
} }
}

注意,我们在这里用了一个Throttle的方法,它可以设置一个时间间隔,在这个时间间隔里面发生的事件,应该只处理一次(最后一个为准),所以运行起来看的效果如下

使用Reactive Extensions(Rx),对短时间内多次发生的事件限流

这里显示的结果取决于你输入的速度。

值得一提的是,在WPF中如果应用双向绑定的技术,结合MVVM来做开发的话,对于此类事情的处理,可能会有一个简单的做法(不需要用到额外的组件),这是由于在WPF 4.5中,对于绑定数据的更新,有多了一个选项:Delay

有兴趣的朋友可以参考http://msdn.microsoft.com/zh-cn/library/vstudio/system.windows.data.bindingbase.delay.aspx

上一篇:CPU上下文切换详解


下一篇:Android 常用adb shell 命令(转)