Quartz 调度器执行一个 Runnable答案

【问题标题】：Quartz scheduler execute an RunnableQuartz 调度器执行一个 Runnable
【发布时间】：2020-11-26 12:38:19
【问题描述】：

Quartz 调度器可以执行 Runnable 吗？

例如，我有以下代码由弹簧TaskScheduler 运行：

[...]
@Autowired
@Qualifier(IntegrationConfiguration.TASK_SCHEDULER_INTEGRATION_NAME)
private TaskScheduler taskScheduler;

[...]
ScheduledFuture<?> scheduledFuture = taskScheduler.schedule(new Runnable() {

    @Override
    public void run() {
        try {
            execucaoJobService.executa(jobName, execucaoJobDto, jobScheduleId);
        } catch (JobExecutionException e) {
            LOG.error("Job Execution fails", e);
        }
    }
}, new CronTrigger(cronExpression));
[...]

我想用 Quartz 做类似上面代码的事情，我知道有 QuartzJobBean 类，但是这个仅适用于静态代码，我需要传递 cronExpression 和其他参数动态。

【问题讨论】：

标签： java spring-boot quartz

【解决方案1】：

您可以通过JobDataMap 定义一个接受Runnable 的作业，并在执行时运行它。

工作应该是这样的：

public final class RunnableJob implements Job {

    public static final String RUNNABLE_KEY = "RUNNABLE_KEY";

    public RunnableJob() {
        // Explicit constructor is required by Quartz.
    }

    @Override
    public void execute(JobExecutionContext jobExecutionContext) {
        final var runnable = (Runnable) jobExecutionContext.getJobDetail().getJobDataMap().get(RUNNABLE_KEY);
        runnable.run();
    }
}

你在哪里安排你的工作，它看起来像这样：

        final var cronTrigger = TriggerBuilder.newTrigger()
            .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
            .build();

        final var jobDetail = JobBuilder.newJob(RunnableJob.class)
            .setJobData(new JobDataMap(Map.of(RunnableJob.RUNNABLE_KEY,
                (Runnable) () -> {
                    // Do whatever you want to do
                })))
            .build();

        scheduler.scheduleJob(jobDetail, cronTrigger);

【讨论】：

【解决方案2】：

我找到了这个代码：QuartzScheduledExecutorService.java，它可以帮助我解决这个问题。也许它可以在未来帮助别人。

【讨论】：