XXL-JOB几个关键线程、队列的分析

XXL-JOB在初始化时，会执行一系列的方法，这些方法启动了一系列的线程，还创建了一些队列，这些线程、队列对于整个任务调度来说都是至关重要的，现在就来分析一下这些线程、队列。

调度中心的初始化

1. 调度中心启动时，会先执行 com.xxl.job.admin.core.conf.XxlJobAdminConfig#afterPropertiesSet 这个方法（因为这个类是实现 org.springframework.beans.factory.InitializingBean 接口的）

2. 这个方法的代码

   @Override
   public void afterPropertiesSet() throws Exception {
    adminConfig = this;
   
    xxlJobScheduler = new XxlJobScheduler();
    xxlJobScheduler.init();
   }

3. 关键在于执行了， xxlJobScheduler.init() 。再来看看这个方法的内容（通过添加一些注释）：

   public void init() throws Exception {
    // 初始化i18n信息
    initI18n();
   
    // 调度中心监听执行器的注册
    // 这里主要是监听自动注册的执行器，并且实时更新其状态
    // 线程分析见4
    JobRegistryMonitorHelper.getInstance().start();
   
    // 调度中心监控失败的调度
    // 首先进行重试，重试的次数为页面配置，每次减1
    // 发送失败告警邮件
    JobFailMonitorHelper.getInstance().start();
   
    // 调度中心调度监控
    // 源码分析见5
    JobTriggerPoolHelper.toStart();
   
    // 调度中心的日志整理
    JobLogReportHelper.getInstance().start();
   
    // 调度线程
    // 用于扫描即将要执行的任务（当前时间+5000毫秒）
    // 源码分析可见https://www.cnblogs.com/jiangyang/p/11576931.html
    JobScheduleHelper.getInstance().start();
   
    logger.info(">>>>>>>>> init xxl-job admin success.");
   }

4. 调度中心监听执行器的注册

   public void start(){
    // 创建一个线程，该线程用来监听库中新增的自动注册的执行器
    registryThread = new Thread(new Runnable() {
        @Override
        public void run() {
            // 该线程中运行着一个while死循环
            // 当且仅当调用stop方法，将toStop设置为true，死循环结束，也就是监听结束
            // 基本上每个监听线程都是在这么做的
            while (!toStop) {
                // ...........
                // 这里设置线程休眠30s，意味着30s检测一次执行器的状态
                try {
                    TimeUnit.SECONDS.sleep(RegistryConfig.BEAT_TIMEOUT);
                } catch (InterruptedException e) {
                    if (!toStop) {
                        logger.error(">>>>>>>>>>> xxl-job, job registry monitor thread error:{}", e);
                    }
                }
            }
            logger.info(">>>>>>>>>>> xxl-job, job registry monitor thread stop");
        }
    });
    // 设置线程相关参数
    registryThread.setDaemon(true);
    registryThread.setName("xxl-job, admin JobRegistryMonitorHelper");
    registryThread.start();
   }

5. 调度中心调度监控
   这里启动了两个线程池： fastTriggerPool 和 slowTriggerPool ，当一个job的执行时间超过500毫秒时，将会被放入 slowTriggerPool 线程池来运行