Docker环境下Elasticsearch插件集成的Quartz调度器无法停止问题咨询

问题根因 #

1. 变量可见性问题：你代码里的stopped变量没有加volatile修饰，Java内存模型中，不同线程对普通变量的修改不会立即同步到主内存，执行任务的线程可能一直读取到的是stopped=false的缓存值。Windows平台的内存模型实现对变量可见性的处理更宽松，所以能正常生效，Linux等平台下就会出现修改不生效的问题。
2. 任务执行逻辑阻塞：你仅在execute方法入口判断了一次stopped状态，后续调用rs.start()如果是同步阻塞执行的逻辑，就算stopped被修改为true，也不会中断正在运行的rs.start()方法，任务会一直处于运行状态，Quartz识别到任务还在运行，就会返回interrupt()为false，且无法删除运行中的任务。
3. Elasticsearch类加载隔离问题：ES插件使用独立的子类加载器加载插件内的类，如果你初始化Quartz时没有指定类加载器，Quartz默认会使用系统类加载器实例化Job，导致调度器持有的Job实例和你预期的实例不匹配，无法触发interrupt()方法。

解决方案 #

• 修复变量可见性：将stopped变量添加volatile修饰，或者改用AtomicBoolean类型，保证多线程下修改的可见性：

volatile boolean stopped = false;
// 或者改用AtomicBoolean实现更稳妥的原子操作
private AtomicBoolean stopped = new AtomicBoolean(false);

对应的interrupt方法同步修改即可。

• 改造ReportService的执行逻辑：在rs.start()的业务逻辑中周期性检查stopped状态或者线程中断信号，收到中断信号后主动退出执行，比如rs.start()中如果有循环逻辑，每轮循环都判断状态：

// ReportService的start方法改造示例
public void start(SchedulerContext schedulerContext, boolean stopped) {
    while(!stopped && !Thread.currentThread().isInterrupted()) {
        // 原有业务逻辑
    }
}

在execute方法调用时传入stopped变量即可。

• 适配ES的类加载机制：初始化Quartz调度器时，临时替换线程上下文类加载器为插件的类加载器，避免Job类加载不匹配的问题：

ClassLoader originClassLoader = Thread.currentThread().getContextClassLoader();
Scheduler scheduler;
try {
    // 替换为当前插件类的类加载器
    Thread.currentThread().setContextClassLoader(ReportJob.class.getClassLoader());
    scheduler = new StdSchedulerFactory().getScheduler();
} finally {
    // 恢复原有类加载器
    Thread.currentThread().setContextClassLoader(originClassLoader);
}

• 优化任务删除流程：删除任务前先暂停任务的触发器避免新的调度触发，再等待当前正在运行的任务实例退出后再执行删除：

JobKey jobKey = new JobKey(jobName, JOB_GROUP);
// 暂停任务，不再触发新的执行
scheduler.pauseJob(jobKey);
// 发送中断信号
boolean interruptRes = scheduler.interrupt(jobKey);
System.out.println("interrupt: " + interruptRes);
// 最多等待3秒，确认任务退出
int retry = 0;
while (retry < 30) {
    boolean hasRunningJob = scheduler.getCurrentlyExecutingJobs()
            .stream()
            .anyMatch(ctx -> ctx.getJobDetail().getKey().equals(jobKey));
    if (!hasRunningJob) {
        break;
    }
    Thread.sleep(100);
    retry++;
}
// 删除任务
boolean deleteRes = scheduler.deleteJob(jobKey);
System.out.println("deleteJob: " + deleteRes);

内容的提问来源于stack exchange，提问作者Ali Kh