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技术!

谢谢!

本文转自博客园张占岭(仓储大叔)的博客,原文链接:LindAgile.SchedulingTask~设计一个不错的任务调度组件,如需转载请自行联系原博主。

目录
相关文章
|
SQL 网络协议 Java
玩转Docker—部署Spring Boot+MySQL工程实战
玩转Docker—部署Spring Boot+MySQL工程实战
|
Python
Python:使用os.path.splitext获取文件扩展名
Python:使用os.path.splitext获取文件扩展名
424 0
|
1天前
|
云安全 人工智能 自然语言处理
|
6天前
|
搜索推荐 编译器 Linux
一个可用于企业开发及通用跨平台的Makefile文件
一款适用于企业级开发的通用跨平台Makefile,支持C/C++混合编译、多目标输出(可执行文件、静态/动态库)、Release/Debug版本管理。配置简洁,仅需修改带`MF_CONFIGURE_`前缀的变量,支持脚本化配置与子Makefile管理,具备完善日志、错误提示和跨平台兼容性,附详细文档与示例,便于学习与集成。
316 116
|
8天前
|
数据采集 人工智能 自然语言处理
Meta SAM3开源:让图像分割,听懂你的话
Meta发布并开源SAM 3,首个支持文本或视觉提示的统一图像视频分割模型,可精准分割“红色条纹伞”等开放词汇概念,覆盖400万独特概念,性能达人类水平75%–80%,推动视觉分割新突破。
615 53
Meta SAM3开源:让图像分割,听懂你的话
|
21天前
|
域名解析 人工智能
【实操攻略】手把手教学,免费领取.CN域名
即日起至2025年12月31日,购买万小智AI建站或云·企业官网,每单可免费领1个.CN域名首年!跟我了解领取攻略吧~
|
5天前
|
人工智能 Java API
Java 正式进入 Agentic AI 时代:Spring AI Alibaba 1.1 发布背后的技术演进
Spring AI Alibaba 1.1 正式发布,提供极简方式构建企业级AI智能体。基于ReactAgent核心,支持多智能体协作、上下文工程与生产级管控,助力开发者快速打造可靠、可扩展的智能应用。
|
4天前
|
弹性计算 人工智能 Cloud Native
阿里云无门槛和有门槛优惠券解析:学生券,满减券,补贴券等优惠券领取与使用介绍
为了回馈用户与助力更多用户节省上云成本,阿里云会经常推出各种优惠券相关的活动,包括无门槛优惠券和有门槛优惠券。本文将详细介绍阿里云无门槛优惠券的领取与使用方式,同时也会概述几种常见的有门槛优惠券,帮助用户更好地利用这些优惠,降低云服务的成本。
270 132

热门文章

最新文章