如果有個操作,我們需要過一會兒再做,或者每隔一段時間就要做一次。可以有很多種做法。 獨立線程 是的,對.NET Framework本身一知半解的程式員才會使用這種方案。不過,現實中這個方案其實並不少見。 public static void Repeat(this Action action, Ti
如果有個操作,我們需要過一會兒再做,或者每隔一段時間就要做一次。可以有很多種做法。
獨立線程
是的,對.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積壓的問題出現。