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技术!
谢谢!
本文转自博客园张占岭(仓储大叔)的博客,原文链接:LindAgile.SchedulingTask~设计一个不错的任务调度组件,如需转载请自行联系原博主。