LindAgile.SchedulingTask~設計一個不錯的任務調度組件

回到目錄

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技術！

謝謝！

回到目錄