文章出處
文章列表
SchedulingTask產生的原因
任務調試主要指定期執行某些任務代碼，之前用過quartz，感覺有些重，使用時需要添加包包，配置管理項時，對于簡單的項目用它就顯得有些臃腫了，不如直接上個簡單的東西來實現，所有才有了今天的SchedulingTask，它被大叔集成到了最新的lindAgile框架里，也是Modules的一個子單元，在項目啟動時由ModuleManager統一完成注冊！
SchedulingTask核心的設計圖
SchedulingTask的注冊
ModuleManager.Create()
.UseDefaultContainer()
.UseLogger()
.UseMockRepository()
.UseDefaultMq();
而對于我們每個Job任務，需要開發人員根據業務要求去編寫，它們將繼承一個叫ScheduleBase的抽象類，此類為我們提供了調度周期，任務執行器等核心的邏輯！
/// <summary> /// 啟動任務 /// </summary> /// <param name="name"></param> /// <param name="action"></param> /// <param name="dueTime">執行方法前的延時時間,毫秒</param> /// <param name="interval">執行方法的時間間隔,毫秒</param> public void StartTask(string name, int interval) { lock (_lockObject) { if (_taskDict.ContainsKey(name)) return; var timer = new Timer(TaskCallback, name, Timeout.Infinite, Timeout.Infinite); _taskDict.Add(name, new TimerTaskModel { Name = name, Callback = Excute, Timer = timer, IntervalMillisecond = interval, Stopped = false }); timer.Change(interval, 0); } }
而它與其它具體JOB的關系，我們可以用一張圖來表示
對于任務的啟動，我們由ScheduleFactory來完成，它會將當前運行時下所有繼承ScheduleBase的Job類都加載到容器里，通過自己的調試周期去定時執行！
/// <summary> /// 開始任務q /// 裝置所有任務，并啟動它的StartTask()方法 /// </summary> public void Run() { foreach (var item in GetAllTypes()) { var obj = Activator.CreateInstance(item, true); MethodInfo methodinfo = item.GetMethod("StartTask"); _iLogger.Logger_Info(string.Format("{0}這個Job開始執行", item.Name)); methodinfo.Invoke(obj, new object[] { item.Name, _intervalMillisecond > 0 ? _intervalMillisecond : item.GetProperty("IntervalMillisecond").GetValue(obj) }); } }
而對于使用者來說，要做的就是建立自己的業務Job和在程序入口添加對Run的使用即可
#region TaskJob sf.UseLogger().Run(); Console.ReadKey(); #endregion
結果如圖
希望各位繼續支持微軟，支持咱們自己的.net技術！
謝謝！
文章列表
全站熱搜
留言列表
