【C#】任务调度的实现原理与组件应用Quartz.Net

Quartz 是一个流行的开源作业调度库，最初由 Terracotta 开发，现在由 Terracotta 的一部分 Oracle 所有。它主要用于在 Java 应用程序中调度作业的执行。Quartz 使用了一种复杂的底层算法来管理任务调度，其中包括任务触发、执行、持久化以及集群支持。

Quartz 的核心组件和底层算法

Quartz.NET是一个功能强大的作业调度框架，用于在C#中实现定时任务。关于Quartz.NET的底层算法，主要涉及以下几个核心元素及其工作原理：

‌1. Scheduler（调度器）‌：

负责整个定时系统的调度，内部通过线程池进行调度。
Scheduler为调度器负责整个定时系统的调度,内部通过线程池进行调度。
SchedulerFactoryBean实现了InitializingBean接口，在初始化bean的时候，会执行afterPropertiesSet方法，该方法将会调用SchedulerFactory(DirectSchedulerFactory 或者 StdSchedulerFactory,通常用StdSchedulerFactory)创建Scheduler。

2. ‌Trigger（触发器）‌：

记录着调度任务的时间规则。
主要有四种类型：SimpleTrigger、CronTrigger、DataIntervalTrigger、NthIncludedTrigger，项目中常用的为SimpleTrigger和CronTrigger。
触发器定义了作业何时被执行。

3‌. JobDetail（作业细节）‌：

定时任务的信息载体，可以记录Job的名字、组及任务执行的具体类和任务执行所需要的参数。

4‌. Job（作业）‌：

任务的真正执行体，承载着具体的业务逻辑。
承载着具体的业务逻辑。

‌5. 线程池（ThreadPool）‌：

执行线程池，一般是使用SimpleThreadPool（线程数量固定的线程池），SimpleThreadPool创建了一定数量的WorkerThread实例来使得Job能够在线程中进行

底层算法详解

触发器匹配：

当有新的触发器被添加到调度器时，调度器会检查当前时间与触发器的启动时间。如果当前时间已经超过了触发器的启动时间，则会将该触发器加入到待执行队列中。

！时间轮（Time Wheel）：

Quartz 使用了一种时间轮（Time Wheel）算法来高效地处理大量定时任务。时间轮是一个环形数据结构，每个槽位代表一个时间间隔。例如，一个每秒触发一次的时间轮将有60个槽位，每个槽位代表一分钟内的每一秒。

  • 添加任务：当新的触发器被创建并加入调度器时，调度器会计算其下一次触发时间，并将其放入对应的时间轮槽位中。

  • 任务执行：到达槽位的时间时，时间轮会触发该槽位中的所有任务。

  • 性能优化：通过这种方式，Quartz 可以非常高效地处理大量定时任务，尤其是在高负载的情况下。

  • 集群支持：当配置为集群模式时，Quartz 使用数据库或其他共享存储来同步所有节点的作业和触发器状态。这涉及到额外的网络通信和状态同步算法，确保所有节点都能看到相同的工作状态。

  • 持久化：对于需要持久化的场景，Quartz 使用 JobStore 来存储作业和触发器的数据。JDBCJobStore 是最常见的实现，它使用 JDBC 连接数据库来存储这些信息。这确保了即使调度器重启，之前安排的任务也不会丢失。

C# 基于Quartz.Net的使用指南‌

Quartz.Net是一个功能强大的开源作业调度框架，它是Java Quartz的.NET版本，广泛应用于需要定时任务调度的场景。Quartz.Net支持复杂的调度需求，如任务的并发执行、任务依赖、任务失败重试等。以下是如何在C#项目中使用Quartz.Net的详细指南。

一、安装Quartz.Net

你可以通过NuGet包管理器安装Quartz.Net。在Visual Studio中，打开“工具”菜单，选择“NuGet包管理器”，然后点击“程序包管理器控制台”。在控制台中输入以下命令来安装Quartz.Net：

Install-Package Quartz

二、创建Job类

Job是一个执行任务的简单.NET类。任务可以是任何C#代码。只需你实现Quartz.IJob接口并且在出现严重错误情况下抛出JobExecutionException异常即可。IJob接口包含唯一的一个方法Execute()，作业从这里开始执行。

using Quartz;
using System;
using System.Threading.Tasks;public class MyJob : IJob
{public async Task Execute(IJobExecutionContext context){await Task.Run(() =>{// 在这里放置你的任务逻辑Console.WriteLine("Executing job...");});}
}

三、创建Scheduler和Trigger

在代码中创建调度器（Scheduler）和触发器（Trigger）来配置和管理任务。

using Quartz;
using Quartz.Impl;
using System;
using System.Threading.Tasks;public class SchedulerManager
{public static async Task Start(){// 获取调度器实例IScheduler scheduler = await new StdSchedulerFactory().GetScheduler();// 启动调度器await scheduler.Start();// 创建任务IJobDetail job = JobBuilder.Create<MyJob>().WithIdentity("job1", "group1").Build();// 创建触发器ITrigger trigger = TriggerBuilder.Create().WithIdentity("trigger1", "group1").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(10) // 每隔10秒执行一次.RepeatForever()) // 无限重复.Build();// 关联任务和触发器await scheduler.ScheduleJob(job, trigger);}
}

四、启动调度器

在你的主程序中启动调度器。

class Program
{public static async Task Main(string[] args){// 启动调度器await SchedulerManager.Start();// 保持程序运行以便观察任务执行情况Console.ReadLine();}
}

五、高级功能

Quartz.Net还支持许多高级功能，如CronTrigger、作业依赖、任务失败重试等。以下是如何使用CronTrigger的一个示例：

// 构建CronTrigger
ITrigger cronTrigger = TriggerBuilder.Create().WithIdentity("cronTrigger", "group1").WithSchedule(CronScheduleBuilder.CronSchedule("0 0 23 1/1 * ?")) // 每天晚上11点执行一次任务.Build();// 关联任务和CronTrigger
await scheduler.ScheduleJob(job, cronTrigger);

六、注意事项

  • 资源释放‌：在程序关闭时，务必停止并释放调度器资源，确保任务正常结束。例如：
await scheduler.Shutdown();
  • 日志管理‌：使用日志记录任务的执行情况，以便更好地维护和排查问题。
  • ‌ 业务逻辑扩展‌：在实际场景中，可能需要根据业务需求进一步调整任务的执行逻辑和触发器的配置。

通过遵循以上步骤，你可以轻松地在C#项目中使用Quartz.Net来实现定时任务调度功能。Quartz.Net的灵活性和强大功能将帮助你更好地管理定时任务，提高应用程序的效率和可靠性。

Quartz.NET 的任务是如何被执行的？

在Quartz.NET中，当任务（Job）被触发器（Trigger）触发时，Quartz.NET会使用一个线程来处理该任务的执行。具体来说，Quartz.NET内部维护了一个线程池（ThreadPool），这个线程池负责提供线程来执行被触发的任务。

以下是关于任务触发时线程处理的一些详细信息：
‌1. 线程池（ThreadPool）‌：
Quartz.NET使用线程池来管理执行任务所需的线程。线程池中的线程可以被重用以执行多个任务，从而提高效率和性能。

2‌. Worker Thread‌：
当一个任务被触发时，Quartz.NET会从线程池中获取一个可用的线程（通常称为Worker Thread）来执行该任务。
Worker Thread负责调用任务的Execute方法，并在此方法内执行具体的业务逻辑。

‌3. 线程管理‌：
Quartz.NET的线程池配置可以通过配置文件或编程方式进行设置，包括线程池的大小、线程优先级等。
线程池会根据任务的执行情况和系统资源动态地分配和管理线程，以确保任务的及时执行和系统的稳定运行。

‌4. 并发执行‌：
Quartz.NET支持多个任务并发执行。这意味着如果有多个任务被同时触发，Quartz.NET会尝试使用线程池中的多个线程来同时执行这些任务。

在Quartz.NET中，任务可以分为无状态（stateless）和有状态（stateful）两种。

  • **无状态任务，**它们默认是并发执行的，即如果前一个任务还没有执行完，到了下一个触发点，新的任务实例还是会被触发和执行‌。这意味着，如果任务卡住了，它不会阻止下一个任务实例的触发和执行。
  • **有状态任务，**情况就不同了。有状态任务不能被并行执行，只有上一次触发的任务被执行完之后，才能触发下一次执行‌1。因此，如果一个有状态任务卡住了，那么在下一个触发点，这个任务不会被再次触发执行，直到当前卡住的任务执行完成或被中断。

此外，Quartz.NET还提供了一些配置和策略来控制任务的行为。例如，可以使用[DisallowConcurrentExecution]标记来禁止任务的并发执行，这样即使任务是无状态的，也会等待前一个任务执行完成后再执行下一个任务‌。另外，还可以设置Trigger的Misfire策略，以控制在错过触发时间时任务的行为，比如选择重新触发任务或放弃触发任务‌。

综上所述，如果任务卡住了，是否会到下一个任务触发点再被执行一次，取决于任务的执行模式（无状态或有状态）、是否使用了[DisallowConcurrentExecution]标记以及Trigger的Misfire策略等配置。

‌5. 线程安全性‌：
由于多个任务可能会并发执行，因此在编写任务代码时需要注意线程安全性问题。
确保任务中的共享资源（如数据库连接、文件系统等）被正确地同步和访问，以避免出现数据竞争或其他并发问题。

综上所述，当Quartz.NET中的任务被触发时，它会使用线程池中的一个线程来处理该任务的执行。这个线程负责调用任务的Execute方法，并在此方法内执行具体的业务逻辑。开发者在编写任务代码时需要注意线程安全性问题，以确保任务的正确执行和系统的稳定运行。

总结

Quartz 的底层算法结合了高效的时间管理（通过时间轮）和灵活的存储机制（通过 JobStore），使其能够在各种环境中有效地调度和管理作业。无论是单机还是集群环境，Quartz 都提供了强大的功能和灵活性来满足不同的需求。通过理解和优化这些底层算法，可以更好地利用 Quartz 的功能并提高应用程序的性能和可靠性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/69612.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

torch_bmm验算及代码测试

torch_bmm验算及代码测试

文章目录 1. torch_bmm2. pytorch源码 1. torch_bmm torch.bmm的作用是基于batch_size的矩阵乘法,torch.bmm的作用是对应batch位置的矩阵相乘&#xff0c;比如&#xff0c; mat1的第1个位置和mat2的第1个位置进行矩阵相乘得到mat3的第1个位置mat1的第2个位置和mat2的第2个位置…
阅读更多...
shell+kafka实现服务器健康数据搜集

shell+kafka实现服务器健康数据搜集

今天有一个徒弟问我&#xff0c;分发、代理服务器都装有kafka&#xff0c;如何快速收集服务器的健康数据&#xff0c;每10秒就收集一次&#xff1f; 我当时听完之后&#xff0c;楞了一下&#xff0c;然后说出了我的见解&#xff1a;认为最快速的方法无法就是建议shell脚本直接采…
阅读更多...
web前端布局--使用element中的Container布局容器

web前端布局--使用element中的Container布局容器

前端页面&#xff0c;跟Qt中一样&#xff0c;都是有布局设置的。 先布局&#xff0c;然后再在各布局中添加显示的内容。 Element网站布局容器&#xff1a;https://element.eleme.cn/#/zh-CN/componet/container 1.将element相应的布局容器代码layout&#xff0c;粘贴到vue项…
阅读更多...
vcredist_x64.exe 是 Microsoft Visual C++ Redistributable 的 64 位版本

vcredist_x64.exe 是 Microsoft Visual C++ Redistributable 的 64 位版本

vcredist_x64.exe 是 Microsoft Visual C++ Redistributable 的 64 位版本，它提供了运行基于 Visual C++ 编写的应用程序所需的库文件。许多 Windows 应用程序都依赖这些库来正常运行，特别是使用 Visual Studio 编译的程序。 用途和重要性： 运行时库：vcredist_x64.exe 安装…
阅读更多...
一个简单的Windows TCP服务器实现

一个简单的Windows TCP服务器实现

初始化 WSADATA wsaData; SOCKET serverSocket, clientSocket; struct sockaddr_in serverAddr { 0x00 }; struct sockaddr_in clientAddr { 0x00 }; int clientAddrLen sizeof(clientAddr);if (WSAStartup(MAKEWORD(2, 2), &wsaData) ! 0) {printf("WSAStartup f…
阅读更多...
AF3 drmsd函数解读

AF3 drmsd函数解读

drmsd（distance Root Mean Square Deviation，距离均方根偏差）函数在AlphaFold3的 src.utils.validation_metrics模块中定义，用于计算两个蛋白质结构（或其他分子结构）之间的距离偏差。它衡量了两个结构的 成对原子间距离 差异，而不是直接比较原子坐标。这种度量方式比 RM…
阅读更多...
macbook2015升级最新MacOS 白苹果变黑苹果

macbook2015升级最新MacOS 白苹果变黑苹果

原帖&#xff1a;https://www.bilibili.com/video/BV13V411c7xz/MAC OS系统发布了最新的Sonoma&#xff0c;超酷的动效锁屏壁纸&#xff0c;多样性的桌面小组件&#xff0c;但是也阉割了很多老款机型的升级权利&#xff0c;所以我们可以逆向操作&#xff0c;依旧把老款MAC设备强…
阅读更多...
建筑物损坏程度分割数据集labelme格式2816张5类别

建筑物损坏程度分割数据集labelme格式2816张5类别

数据集格式&#xff1a;labelme格式(不包含mask文件&#xff0c;仅仅包含jpg图片和对应的json文件) 图片数量(jpg文件个数)&#xff1a;2816 标注数量(json文件个数)&#xff1a;2816 标注类别数&#xff1a;5 标注类别名称:["minor-damage","destroyed&quo…
阅读更多...
ReactNative进阶（五十九）：存量 react-native 项目适配 HarmonyOS NEXT

ReactNative进阶（五十九）：存量 react-native 项目适配 HarmonyOS NEXT

文章目录 一、前言二、ohos_react_native2.1 Fabric2.2 TurboModule2.2.1 ArkTSTurboModule2.2.2 cxxTurboModule&#xff1a; 三、拓展阅读 一、前言 2024年10月22日19:00&#xff0c;华为在深圳举办“原生鸿蒙之夜暨华为全场景新品发布会”&#xff0c;主题为“星河璀璨&…
阅读更多...
Golang GORM系列：GORM CRUM操作实战

Golang GORM系列：GORM CRUM操作实战

在数据库管理中&#xff0c;CRUD操作是应用程序的主干&#xff0c;支持数据的创建、检索、更新和删除。强大的Go对象关系映射库GORM通过抽象SQL语句的复杂性&#xff0c;使这些操作变得轻而易举。本文是掌握使用GORM进行CRUD操作的全面指南&#xff0c;提供了在Go应用程序中有效…
阅读更多...
k8s部署elasticsearch

k8s部署elasticsearch

前置环境：已部署k8s集群，ip地址为 192.168.10.1~192.168.10.5，总共5台机器。 1. 创建provisioner制备器（如果已存在，则不需要） 制备器的具体部署方式，参考我之前的文章：k8s部署rabbitmq-CSDN博客 2. 编写wms-elk-data-sc.yaml配置文件 apiVersion: storage.k8s.io/…
阅读更多...
【Windows】PowerShell 缓存区大小调节

【Windows】PowerShell 缓存区大小调节

PowerShell 缓存区大小调节 方式1 打开powershell 窗口属性调节方式2&#xff0c;修改 PowerShell 配置文件 方式1 打开powershell 窗口属性调节 打开 CMD&#xff08;按 Win R&#xff0c;输入 cmd&#xff09;。右键标题栏 → 选择 属性&#xff08;Properties&#xff09;…
阅读更多...
Json-RPC框架项目(一)

Json-RPC框架项目(一)

目录 1. 项目介绍: 2. 技术选择; 3. 第三方库介绍; 4. 项目功能; 5. 模块功能; 6. 项目实现: 1. 项目介绍: RPC是远程过程调用, 像调用本地接口一样调用远程接口, 进行完成业务处理, 计算任务等, 一个完整的RPC包括: 序列化协议, 通信协议, 连接复用, 服务注册, 服务发…
阅读更多...
C++智能指针的使用

C++智能指针的使用

文章目录 智能指针的使用和原理智能指针的使用场景RAII和智能指针C标准库智能指针的使用 智能指针的使用和原理 智能指针的使用场景 1. 下面的程序中&#xff0c;new了以后&#xff0c;我们也delete了&#xff0c;但是因为抛异常导致后面的delete没有得到执行&#xff0c;所以…
阅读更多...
tomcat如何配置保存7天滚动日志

tomcat如何配置保存7天滚动日志

在 Tomcat 中&#xff0c;logging.properties 文件是用于配置 Java 日志框架&#xff08;java.util.logging&#xff09;的。若要实现 catalina.out 日志保存 7 天&#xff0c;且每天的日志文件名带有时间戳&#xff0c;可以按以下步骤进行配置&#xff1a; 1. 备份原配置 在修…
阅读更多...
如何解决ChatGPT API响应慢的问题

如何解决ChatGPT API响应慢的问题

随着人工智能技术的快速发展&#xff0c;OpenAI的ChatGPT API已广泛应用于多种场景中&#xff0c;从客户服务到内容创作&#xff0c;甚至在教育、娱乐等领域也有着重要的应用。然而&#xff0c;很多开发者和使用者会遇到一个共同的问题——ChatGPT API响应速度较慢&#xff0c;…
阅读更多...
深度整理总结MySQL——MySQL加锁工作原理

深度整理总结MySQL——MySQL加锁工作原理

MySQL加锁工作原理 前言前置知识- 锁为什么加在索引上锁的粒度优化提高并发性避免全表扫描优化死锁处理解决幻读问题 什么SQL语句会加行级锁MySQL是如何加行级锁场景模拟代码唯一索引等值查询退化为记录锁为什么会退化为记录锁分析加了什么锁为什么会退化为间隙锁为什么我可以插…
阅读更多...
Deepseek系列从v3到R易背面经版

Deepseek系列从v3到R易背面经版

deepseek v3 base要点 MTP : Multi-Token Prediction 训练时&#xff1a; 1. 把前一个block中input tokens经过embedding layer和transformer block的输出&#xff0c;进入output head之前的内容记为h&#xff0c;与下一个block的input tokens经过embedding layer输出的内容都…
阅读更多...
大模型融入推荐系统

大模型融入推荐系统

结合项目实际给用户推荐&#xff0c;比如是商家项目&#xff0c;用户问了几个关于商品的信息&#xff0c;大模型就可以根据根据用户画像&#xff0c;给用户推荐商品。 我们现在做的是针对于用户学习的推荐&#xff0c;首先我们要对我们的数据进行处理&#xff0c;提取出我们数…
阅读更多...
MariaDB MaxScale实现mysql8主从同步读写分离

MariaDB MaxScale实现mysql8主从同步读写分离

一、MaxScale基本介绍 MaxScale是maridb开发的一个mysql数据中间件&#xff0c;其配置简单&#xff0c;能够实现读写分离&#xff0c;并且可以根据主从状态实现写库的自动切换&#xff0c;对多个从服务器能实现负载均衡。 二、MaxScale实验环境 中间件192.168.121.51MaxScale…
阅读更多...
最新文章

Copyright @ 2022~2023