quartz源码-Schedule启动过程分析

2024-09-03 16:44
文章标签 分析 源码 启动 过程 quartz schedule

本文主要是介绍quartz源码-Schedule启动过程分析，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

演示demo

public class HelloJob implements Job {private String j1;public void setJ1(String j1) {this.j1 = j1;}@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("************任务开始执行***********");System.out.println(j1);System.out.println("任务执行结束！");}
}

public class Main {public static void main(String[] args) throws Exception {JobDetail job1 = newJob(HelloJob.class)// 往JobDataMap中传入数据.usingJobData("j1", "我是job1")// 给JobDetail定义一个唯一标识，group+name唯一确定一个JobDetail.withIdentity("job1", "group1").build();Trigger trigger = newTrigger()// 给Trigger定义一个唯一标识，group+name唯一确定一个Trigger.withIdentity("trigger1", "group1")// 往JobDataMap中传入数据.usingJobData("t1", "v1")// 规定Trigger触发时间，这里是每秒触发一次.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever()).build();Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();// 把Trigger和JobDetail绑定起来scheduler.scheduleJob(job1, trigger);scheduler.start();}
}

我们主要分析这三行代码

Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.scheduleJob(job1, trigger);
scheduler.start();

Schedule的获取

Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

我们跳转到StdSchedulerFactory涉及到的代码，主要操作如下：

  1. 解析quartz.properties文件，把其中的数据存储到变量PropertiesParser cfg;中
  2. **获取Scheduler。**会从SchedulerRepository获取Scheduler；获取不到就会通过instantiate()实例化一个新的Scheduler，这个新的Scheduler中的属性的值就是从前面变量PropertiesParser cfg中获取，实例化的Schedule会存储到SchedulerRepository中去。
public class StdSchedulerFactory implements SchedulerFactory {public static Scheduler getDefaultScheduler() throws SchedulerException {StdSchedulerFactory fact = new StdSchedulerFactory();return fact.getScheduler();}public Scheduler getScheduler() throws SchedulerException {if (cfg == null) {// 解析quartz.properties文件，存储到变量PropertiesParser cfg;中initialize();}SchedulerRepository schedRep = SchedulerRepository.getInstance();Scheduler sched = schedRep.lookup(getSchedulerName());if (sched != null) {if (sched.isShutdown()) {schedRep.remove(getSchedulerName());} else {return sched;}}// 实例化Schedulersched = instantiate();return sched;}
}

我们看到SchedulerRepository是个单例模式，用HashMap<String, Scheduler> schedulers;变量存储所有实例化的scheduler，能够保证获取到scheduler唯一性。

public class SchedulerRepository {private HashMap<String, Scheduler> schedulers;private static SchedulerRepository inst;private SchedulerRepository() {schedulers = new HashMap<String, Scheduler>();}public static synchronized SchedulerRepository getInstance() {if (inst == null) {inst = new SchedulerRepository();}return inst;}public synchronized Scheduler lookup(String schedName) {return schedulers.get(schedName);}
}

job和trigger的绑定和存储

scheduler.scheduleJob(job1, trigger);

我们跳转到StdScheduler类中，会发现StdScheduler类什么也没做，只是把其中的方法转去调用QuartzScheduler类中对应的方法。

public class StdScheduler implements Scheduler { private QuartzScheduler sched;public Date scheduleJob(JobDetail jobDetail, Trigger trigger) throws SchedulerException {return sched.scheduleJob(jobDetail, trigger);}
}

来到QuartzScheduler类中对应方法，主要操作如下：

  1. 把trigger和job建立绑定关系
  2. 计算trigger的第一次触发时间
  3. 存储trigger和job
public class QuartzScheduler implements RemotableQuartzScheduler {// 包含创建QuartzScheduler实例所需的所有资源（JobStore、ThreadPool等）。private QuartzSchedulerResources resources;public Date scheduleJob(JobDetail jobDetail,Trigger trigger) throws SchedulerException {validateState();if (jobDetail == null) {throw new SchedulerException("JobDetail cannot be null");}if (trigger == null) {throw new SchedulerException("Trigger cannot be null");}if (jobDetail.getKey() == null) {throw new SchedulerException("Job's key cannot be null");}if (jobDetail.getJobClass() == null) {throw new SchedulerException("Job's class cannot be null");}OperableTrigger trig = (OperableTrigger)trigger;// 1.把trigger和job建立绑定关系// 判断trigger是不是已经绑定了其他job，没有绑定直接绑定给定的jobif (trigger.getJobKey() == null) {trig.setJobKey(jobDetail.getKey());} else if (!trigger.getJobKey().equals(jobDetail.getKey())) {throw new SchedulerException("Trigger does not reference given job!");}trig.validate();// 2.计算第一次点火时间Calendar cal = null;if (trigger.getCalendarName() != null) {cal = resources.getJobStore().retrieveCalendar(trigger.getCalendarName());}Date ft = trig.computeFirstFireTime(cal);if (ft == null) {throw new SchedulerException("Based on configured schedule, the given trigger '" + trigger.getKey() + "' will never fire.");}// 3.存储JobDetail和Triggerresources.getJobStore().storeJobAndTrigger(jobDetail, trig);notifySchedulerListenersJobAdded(jobDetail);notifySchedulerThread(trigger.getNextFireTime().getTime());notifySchedulerListenersSchduled(trigger);return ft;}
}

启动

scheduler.start();

跳转到StdScheduler类

public class StdScheduler implements Scheduler {private QuartzScheduler sched;public void start() throws SchedulerException {sched.start();}
}

跳转到QuartzScheduler#start()方法。这个方法主要是唤醒QuartzSchedulerThread主线程

public void start() throws SchedulerException {if (shuttingDown|| closed) {throw new SchedulerException("The Scheduler cannot be restarted after shutdown() has been called.");}// QTZ-212 : calling new schedulerStarting() method on the listeners// right after entering start()notifySchedulerListenersStarting();if (initialStart == null) {initialStart = new Date();this.resources.getJobStore().schedulerStarted();            startPlugins();} else {resources.getJobStore().schedulerResumed();}// 唤醒QuartzSchedulerThread主线程schedThread.togglePause(false);getLog().info("Scheduler " + resources.getUniqueIdentifier() + " started.");notifySchedulerListenersStarted();
}

这个QuartzSchedulerThread类会在QuartzScheduler实例化的时候就会被创建并开始运行。

public class QuartzScheduler implements RemotableQuartzScheduler {public QuartzScheduler(QuartzSchedulerResources resources, long idleWaitTime, @Deprecated long dbRetryInterval)throws SchedulerException {// ......(省略其他代码)this.schedThread = new QuartzSchedulerThread(this, resources);ThreadExecutor schedThreadExecutor = resources.getThreadExecutor();schedThreadExecutor.execute(this.schedThread);// ......(省略其他代码)}	
}

跳转到QuartzSchedulerThread#run()方法，这个线程开始执行时，paused && !halted.get()这个条件一直满足，会不断执行sigLock.wait(1000L)。直到togglePause(false)调用时，就会改变paused=false，同时会唤醒sigLock.wait(1000L)这个地方，跳出while (paused && !halted.get())这个循环，去触发定时任务。

public class QuartzSchedulerThread extends Thread {private boolean paused;private final Object sigLock = new Object();private AtomicBoolean halted;void togglePause(boolean pause) {synchronized (sigLock) {paused = pause;if (paused) {signalSchedulingChange(0);} else {sigLock.notifyAll();}}}@Overridepublic void run() {int acquiresFailed = 0;while (!halted.get()) {try {// 检查是否需要暂停，当QuartzScheduleThread实例化时，paused=true，进入等待，// 直到调用QuartzScheduler#start()方法时会调用sigLock.notifyAll()。唤醒该线程synchronized (sigLock) {while (paused && !halted.get()) {try {// wait until togglePause(false) is called...sigLock.wait(1000L);} catch (InterruptedException ignore) {}// 暂停时重置失败计数器，这样我们就不用在取消暂停后再次等待acquiresFailed = 0;}if (halted.get()) {break;}}// ......省略其他代码}}}
}

这篇关于quartz源码-Schedule启动过程分析的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1133479。

相关文章

浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
作业提交过程之HDFSMapReduce

作业提交过程之HDFSMapReduce

作业提交全过程详解 （1）作业提交 第1步：Client调用job.waitForCompletion方法，向整个集群提交MapReduce作业。 第2步：Client向RM申请一个作业id。 第3步：RM给Client返回该job资源的提交路径和作业id。 第4步：Client提交jar包、切片信息和配置文件到指定的资源提交路径。 第5步：Client提交完资源后，向RM申请运行MrAp
阅读更多...
性能分析之MySQL索引实战案例

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题，本文将一起从代码层去分析为什么没有建立索引？ 开源ERP项目地址：https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置
阅读更多...
MySQL数据库宕机，启动不起来，教你一招搞定！

MySQL数据库宕机，启动不起来，教你一招搞定！

作者介绍：老苏，10余年DBA工作运维经验，擅长Oracle、MySQL、PG、Mongodb数据库运维（如安装迁移，性能优化、故障应急处理等）公众号：老苏畅谈运维欢迎关注本人公众号，更多精彩与您分享。 MySQL数据库宕机，数据页损坏问题，启动不起来，该如何排查和解决，本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志，排查哪个表（表空间
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
springboot3打包成war包，用tomcat8启动

springboot3打包成war包，用tomcat8启动

1、在pom中，将打包类型改为war <packaging>war</packaging> 2、pom中排除SpringBoot内置的Tomcat容器并添加Tomcat依赖，用于编译和测试,         *依赖时一定设置 scope 为 provided （相当于 tomcat 依赖只在本地运行和测试的时候有效，         打包的时候会排除这个依赖）<scope>provided
阅读更多...
内核启动时减少log的方式

内核启动时减少log的方式

内核引导选项 内核引导选项大体上可以分为两类：一类与设备无关、另一类与设备有关。与设备有关的引导选项多如牛毛，需要你自己阅读内核中的相应驱动程序源码以获取其能够接受的引导选项。比如，如果你想知道可以向 AHA1542 SCSI 驱动程序传递哪些引导选项，那么就查看 drivers/scsi/aha1542.c 文件，一般在前面 100 行注释里就可以找到所接受的引导选项说明。大多数选项是通过"_
阅读更多...
【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

引言 高斯过程（Gaussian Process，简称GP）是一种概率模型，用于描述一组随机变量的联合概率分布，其中任何一个有限维度的子集都具有高斯分布 文章目录 引言一、高斯过程1.1 基本定义1.1.1 随机过程1.1.2 高斯分布 1.2 高斯过程的特性1.2.1 联合高斯性1.2.2 均值函数1.2.3 协方差函数（或核函数） 1.3 核函数1.4 高斯过程回归（Gauss
阅读更多...
Java ArrayList扩容机制 （源码解读）

Java ArrayList扩容机制 （源码解读）

结论：初始长度为10，若所需长度小于1.5倍原长度，则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1：数组默认长度         2:这是一个共享的空数组实例，用于明确创建长度为0时的ArrayList ，比如通过 new ArrayList<>(0)，ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL
阅读更多...
如何在Visual Studio中调试.NET源码

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时，发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null，再判断Count。 看了一下Count的源码如下： 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2