一定間隔時間下重復執行一個函數的幾個方法


如果有個操作,我們需要過一會兒再做,或者每隔一段時間就要做一次。可以有很多種做法。

獨立線程

是的,對.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積壓的問題出現。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM