如何在Quartz调度库中配置使用自定义Executor执行器

可以直接配置Quartz使用你的自定义重试Executor，不需要将Executor调用逻辑耦合在每个Job的execute方法内，常见实现方式有两种：

方案1：替换Quartz全局线程池 #

Quartz默认使用SimpleThreadPool处理任务执行，你可以通过实现Quartz的ThreadPool接口适配自定义Executor，实现全局替换：

1. 自定义线程池适配类，将任务提交逻辑转发到你的重试Executor：

import org.quartz.spi.ThreadPool;
import org.quartz.SchedulerConfigException;
import java.util.concurrent.Executor;

public class RetryExecutorThreadPool implements ThreadPool {
    private final Executor customRetryExecutor;

    // 构造方法传入你的自定义重试Executor实例
    public RetryExecutorThreadPool(Executor customRetryExecutor) {
        this.customRetryExecutor = customRetryExecutor;
    }

    @Override
    public boolean runInThread(Runnable runnable) {
        // Quartz的任务直接交给你的自定义Executor执行
        customRetryExecutor.execute(runnable);
        return true;
    }

    // 其余接口方法根据你的Executor实际属性实现即可，无特殊要求可返回默认值
    @Override
    public int poolSize() {
        // 替换为你的Executor实际的最大线程数
        return 16;
    }

    @Override
    public void setInstanceId(String schedInstId) {}
    @Override
    public void setInstanceName(String schedName) {}
    @Override
    public void initialize() throws SchedulerConfigException {}
    @Override
    public void shutdown(boolean waitForJobsToComplete) {
        // 可在此处添加Executor的销毁逻辑
    }
}

2. 配置Quartz使用自定义线程池：

• 如果你使用properties文件配置Quartz：

# 指定自定义线程池的全限定类名
org.quartz.threadPool.class = com.yourproject.package.RetryExecutorThreadPool
# 可根据需求添加线程池的自定义配置项

• 如果你使用Spring Boot集成Quartz，直接注册自定义线程池Bean即可被自动识别：

@Bean
public ThreadPool quartzThreadPool(Executor customRetryExecutor) {
    return new RetryExecutorThreadPool(customRetryExecutor);
}

方案2：局部适配（仅部分Job使用自定义Executor） #

如果不需要全局替换Quartz线程池，只想减少重复的Executor调用代码，可以实现JobListener接口，在jobToBeExecuted回调中将自定义Executor注入到Job执行上下文，Job内直接从上下文取Executor调用即可。

注意事项 #

• 建议关闭Quartz自带的失败重试配置，避免和你的自定义Executor的重试逻辑冲突，产生重复重试的问题
• 确保自定义Executor的线程模型不会阻塞Quartz的调度线程，避免影响其他定时任务的触发

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