在Spring/Spring Boot下实现计划任务是很简单的，我们只需通过@EnableScheduling开启计划任务的支持，然后通过@Scheduled注解来制定计划任务，这样的实现解决了我们对计划任务的绝大部分需求。

(资料图)

但在很多时候，通过上述方式实现的计划任务是在代码里写死的，我们需要修改计划任务只能通过修改代码的方式实现。很多时候，我们需要从外部来设置计划任务执行的时间和方式。所以在本文中，我们着重讲解一下如何动态地配置计划任务。

和Spring对异步任务的支持一样，通过@EnableAsync注解开启异步的支持，然后通过@Async注解来指定异步的方法，而真正的异步任务的执行者是TaskExecutor接口，它的实现是ThreadPoolTaskExecutor。

同样，Spring对计划任务的支持也是通过@EnableScheduling开启计划任务的支持，然后通过@Scheduled注解来制定计划任务，而真正的任务执行者是TaskScheduler接口，它的实现是ThreadPoolTaskScheduler。

TaskScheduler的接口有三类主要方法：

public interface TaskScheduler {    //指定时间启动计划任务   ScheduledFuture schedule(Runnable task, Trigger trigger);  ScheduledFuture schedule(Runnable task, Date startTime);  //指定频率启动计划任务   ScheduledFuture scheduleAtFixedRate(Runnable task, Date startTime, long period);   ScheduledFuture scheduleAtFixedRate(Runnable task, long period);   //指定延迟启动计划任务   ScheduledFuture scheduleWithFixedDelay(Runnable task, Date startTime, long delay);   ScheduledFuture scheduleWithFixedDelay(Runnable task, long delay);}

方法的返回值都是ScheduledFuture接口,可以使用它来取消任务或者检查任务是否完成。而实际要执行的任务是Runnable的实现类。

那我们可以通过TaskScheduler来实现动态的计划任务的实现。Spring Boot为我们提供了TaskSchedulingAutoConfiguration自动配置来自动注册TaskScheduler的Bean。所以我们无需配置可直接注入TaskScheduler的Bean即可使用。

Spring Boo同样提供了TaskSchedulingProperties来TaskScheduler进行配置，我们可以通过：spring.task.scheduling的属性进行配置。

新建一个演示项目：

构建需要定时启动的任务

public class RunnableTask implements Runnable{    private String taskName;    private WorkingService workingService;        public RunnableTask(String taskName, WorkingService workingService){        this.taskName = taskName;        this.workingService = workingService;    }        @Override    public void run(){        workingService.work( taskName );    }}

这里为了还原实际，一般我们会在任务中调用Spring容器中的其他类进行操作，在此我们引入了一个WorkingService来真正执行任务。

简单的WorkingService

@Service@Slf4jpublic class WorkingService {    public void work(String taskName){        log.info("当前任务：" + taskName +" 在线程" + Thread.currentThread().getName() + "上运行");    }}

使用TaskScheduler的Bean启动定时任务

@Servicepublic class SchedulingService {    private final TaskScheduler taskScheduler; // 可直接注入TaskScheduler的Bean    private final WorkingService workingService;     //构造器注入，免@Autowired    public SchedulingService(TaskScheduler taskScheduler, WorkingService workingService){         this.taskScheduler = taskScheduler;        this.workingService = workingService;    }    public void schedule(String taskName, String cronExpression){        //RunnableTask不是一个Bean，不能直接注入workingService，在它的构造器直接传入        RunnableTask task = new RunnableTask(taskName,workingService);        CronTrigger cronTrigger = new CronTrigger(cronExpression);       //api接受实际执行的任务，和定时启动的cron表达式        taskScheduler.schedule(task,cronTrigger);    }    public void scheduleAtFixedRate(String taskName, long period){        RunnableTask task = new RunnableTask(taskName,workingService);       //api接受实际执行的任务，和间隔时间        taskScheduler.scheduleAtFixedRate(task, period);    }    public void scheduleWithFixedDelay(String taskName, long delay){        RunnableTask task = new RunnableTask(taskName,workingService);       //api接受实际执行的任务，和延迟时间        taskScheduler.scheduleWithFixedDelay(task, delay);    }}

在启动类设置动态配置

@SpringBootApplication@EnableSchedulingpublic class DynamicTaskSchedulerApplication {   public static void main(String[] args) {      SpringApplication.run(DynamicTaskSchedulerApplication.class, args);   }   @Bean   CommandLineRunner commandLineRunner(SchedulingService schedulingService, WorkingService workingService){      return args -> {         schedulingService.schedule("指定时间任务", "50 * * * * THU");         schedulingService.scheduleAtFixedRate("指定频率任务", 1000);         schedulingService.scheduleWithFixedDelay("指定延迟任务", 1000);      } ;   }}

application.properties的配置

spring.task.scheduling.pool.size=3spring.task.scheduling.thread-name-prefix=wisely-

启动程序验证

（此处已添加书籍卡片，请到今日头条客户端查看）

文章出自：​​爱科学的卫斯理​​，如有转载本文请联系爱科学的卫斯理今日头条号。

关键词： 很多时候 指定时间 我们需要 当前任务 只能通过