当前位置: 代码迷 >> .NET相关 >> Reactive Extension
  详细解决方案

Reactive Extension

热度:258   发布时间:2016-04-24 02:35:47.0
一定间隔时间下重复执行一个函数的几个方法

如果有个操作,我们需要过一会儿再做,或者每隔一段时间就要做一次。可以有很多种做法。

独立线程

是的,对.NET Framework本身一知半解的程序员才会使用这种方案。不过,现实中这个方案其实并不少见。

复制代码
        public static void Repeat(this Action action, TimeSpan interval)        {            new Thread(new ThreadStart(() =>            {                while(true)                {                    Thread.Sleep(interval);                    action();                }            })).Start();        }
复制代码

这个方法,相比其他方法,其实还有一个不容小觑的优势:他保证了action只被一个线程调用,如果这个action没有再在别的地方用到的话,那么action就是线程安全的。

Timer类

在.Net Framework中,一共有4个Timer类。Joe Albahari在他的《Threading in C#》中对这4个Timer进行了充分的对比分析。我就不再赘述了。

但是Timer类的缺点也很明显。

l  非线程安全。除了UI上用的两个Timer类,其它的Timer类都不保证它自己一直是被同一个线程执行。当然,这种多线程的执行方式保证了效率与触发事件的时间精度。

l  操作积压。如果一个Timer,100ms触发一次,但是每次却要执行500ms。你可以想象到,你要做的action,本质上就变成了以这样的方式被执行着:

            while(true)

                action();

如果是多线程的Timer,情况会更糟糕,你的这个action会被多个线程同时执行着。多数情况下,我们应该并不希望事情变成这个样子。但是很可惜,Timer类可不会管你的EventHandler的执行时间是多久,他只是到时间就找个线程把你的action执行一次,无论上次action有没有完成。

l  使用不便。想想我们要做什么:“延迟或定时执行一个函数。”,再来看看需要写的代码,我觉得相对于要做的操作而言,过于复杂了。

复制代码
            Timer timer = new Timer(1000);            timer.Elapsed += (sender, e) => action();            timer.Start();            // 不需要的时候            timer.Dispose();
复制代码

再想想,如果你同时要保证线程安全和避免操作积压,又有多少代码要写?于是,Quartz.NET诞生了,以简化这类定时执行操作的代码。

Reactive Extension

事情就可以被简化成:

         Observable.Interval(interval).Subscribe(i => action());

上面的代码的行为与使用Timer类时的行为一样,有操作积压问题。解决方法有很多。这里给出一个我觉得最简单的。

        public static void Repeat(this Action action, TimeSpan interval)        {            Observable.Defer(action.ToAsync())                      .DelaySubscription(interval)                      .Repeat().Subscribe();        }

上面的方法,保证了每次action执行之间的时间间隔是一定的。所以不会有action积压的问题出现。

  相关解决方案