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~设计一个不错的任务调度组件,如需转载请自行联系原博主。

目录
相关文章
|
3月前
|
分布式计算 监控 大数据
任务调度scheduleX
【8月更文挑战第22天】
521 0
|
4月前
|
缓存 Java 调度
使用scheduleAtFixedRate进行定时任务调度
使用scheduleAtFixedRate进行定时任务调度
|
6月前
|
存储 JavaScript 前端开发
RxJS中的调度器(Scheduler)机制
RxJS中的调度器(Scheduler)机制
168 0
|
6月前
|
消息中间件 安全 Java
一起来探究@Schedule定时任务在分布式产生的问题
一起来探究@Schedule定时任务在分布式产生的问题
382 0
|
11月前
|
缓存 Cloud Native 调度
Fluid支持分层数据缓存本地性调度(Tiered Locality Scheduling)
依赖容器化带来的高效部署、敏捷迭代,以及云计算在资源成本和弹性扩展方面的天然优势,以 Kubernetes 为代表的云原生编排框架吸引着越来越多的 AI 与大数据应用在其上部署和运行。但是数据密集型应用计算框架的设计理念和云原生灵活的应用编排的分歧,导致了数据访问和计算瓶颈。 CNCF开源项目Fluid作为 AI 与大数据云原生应用提供一层高效便捷的数据抽象,将数据从存储抽象出来,针对具体的场景(比如大模型),加速计算访问数据。
879 0
|
Java 调度 Spring
非分布式任务调度@Scheduled
@Scheduled注解是Spring Boot提供的用于定时任务控制的注解,主要用于控制任务在某个指定时间执行,或者每隔一段时间执行,默认是在单线程中执行的
95 0
|
数据可视化 Linux Python
Schedule | 轻量化的定时任务模块
Schedule | 轻量化的定时任务模块
383 0
|
资源调度 分布式计算 运维
阿里巴巴任务调度SchedulerX支持一次性任务
阿里巴巴任务调度SchedulerX2.0支持一次性任务
1229 2
|
Java 调度 Spring
【小家Spring】Spring任务调度核心接口(类)之---TaskScheduler(任务调度器)、Trigger(触发器)、ScheduledTask(调度任务)详解(上)
【小家Spring】Spring任务调度核心接口(类)之---TaskScheduler(任务调度器)、Trigger(触发器)、ScheduledTask(调度任务)详解(上)
【小家Spring】Spring任务调度核心接口(类)之---TaskScheduler(任务调度器)、Trigger(触发器)、ScheduledTask(调度任务)详解(上)
|
缓存 资源调度 运维
SchedulerX 如何帮助用户解决分布式任务调度难题?
本文分别对任务调度平台的资源定义、可视化管控能力、分布式批处理能力进行了简述,并基于 SchedulerX 的能力结合实际业务场景提供了一些基础参考案例。希望通过上述内容能让大家方便地熟悉任务调度平台接入使用概况,对于现有用户也可结合自身团队特点进行平台资源管控隔离,以及在产品业务量增长后通过分布式批处理能力来提升处理效率。
SchedulerX 如何帮助用户解决分布式任务调度难题?