chenhaoblog

quartz框架(十)-QuartzShedulerThread

QuartzSchedulerThread

本篇博文,博主将介绍QuartzSchedulerThread的相关内容。话不多说,直接进入正题。

什么是QuartzSchedulerThread?

从源码和该类的名称上,QuartzSchedulerThread首先是一个线程类,因此它继承了Thread类。从这一点上看,代码的自解释性非常重要。

从quartz框架整体上而言,QuartzSchedulerThread相当于管理者线程,它从JobStore中获取需要触发的任务,交给ThreadPool线程池去分配。接着ThreadPool线程池则会从空闲的工作者线程集合中选取一个工作者线程,把任务分配给该线程执行。

属性定义

  1. qs,QuartzScheduler对象的引用
  2. qsRsrcs,QuartzSchedulerResources对象的引用
  3. sigLock,信号锁
  4. signaled,是否有信号
  5. signaledNextFireTime,信号通知后的下一次触发时间
  6. paused,是否暂停
  7. halted,是否停止
  8. random,随机数
  9. idleWaitTime,空闲等待时间,也就是QuartzShedulerThread在处理完一批Job之后,会进行等待的时间(这期间如果没有信号通知它的话)
  10. ...

togglePause方法

QuartzShedulerThread对象在实例化的时候,此时就处于paused状态(paused为ture)。为什么实例化的时候就处于paused状态呢,因为如果此时没有对应的触发器和Job加入到JobStore的话,QuartzShedulerThread执行主逻辑会占用和消耗资源(比如锁的抢占,无效的查询等)。

那么什么时候QuartzShedulerThread才不处于paused状态呢?我们查看源码可知,在quartzSheduler准备好需要对应的资源后,并且在它的start方法调用的时候,quartzSheduler就会调用QuartzShedulerThread的togglePause方法。不知道细心的小伙伴有没有发现,quartzSheduler的start方法,就是对应设计模式中的外观模式。togglePause逻辑如下:

  1. 获取sigLock锁。
  2. 设置paused为传入的值。
  3. 如果传入的值为false,则通知所有等待在sigLock上的线程。
  4. 如果传入的值为true。
  5. 设置signaled为true。
  6. signaledNextFireTime为0。
  7. 通知所有等待在sigLock上的线程。

halt方法

在quartzScheduler停止的时候会调用quartzSchedulerThread的halt方法,也就是去修改quartzSchedulerThread的循环标志halted为false。halt方法逻辑如下:

  1. 获取sigLock锁。
  2. 设置halted为true。
  3. 判断当前quartzSchedulerThread是否处于paused状态,如果处于paused状态就直接通知等待在该sigLock锁上的所有线程。
  4. 如果不处于paused状态,那么就需要通知quartzSheduler的主处理逻辑发生重大变化,此时signaled为true, signaledNextFireTime时间为0。
  5. 如果传入的wait值为true,会调用quartzSchedulerThread的join方法。(也就是需要把当前线程执行完毕,调用者线程才能继续执行。)

run方法

run方法是quartzSchedulerThread的主处理逻辑。它的方法逻辑如下:

  1. 首先是一个while循环,循环标记是halt。这个是线程长时间运行的处理套路。
  2. 判断当前是否处于paused状态,并且halt为false。如果是的话,则需要进行有条件等待( sigLock.wait(1000L))。
  3. 如果此时从sigLock唤醒时,halted值为false,那么应该直接跳出循环,
  4. 接着阻塞式的获取线程池中可用的空闲线程数。如果可用线程数大于0才继续执行。
  5. 接着从JobStore中获取一定时间范围内(now+idleWaitTime)的触发器。
  6. 如果触发器个数大于0,则获取trigger集合的第一个元素,然后阻塞式判断它的下一次触发时间与当前时间之差是否少于2毫秒。
  7. 如果小于2毫秒的话,判断当前quartzSchedulerThread是否处于halted状态。
  8. 如果当前不处于halted状态,则调用对应JobStore的triggersFired方法。
  9. 接着实例化JobRunShell,并传入线程池进行分配。
  10. 最后quartzSchedulerThread就进行有时间的等待(随机等待一个时间,时间值小于idleWaitTime)。

博主微信公众号

相关文章: