Springboot使用多线程并发执行定时任务
Spring Boot 使用Spring自带的Schedule来实现定时任务变得非常简单和方便。
- 开启缓存注解
@SpringBootApplication
@EnableScheduling //开启定时任务
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
- 编写定时任务
@Component
public class ScheduledTasks {
private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);
// cron接受cron表达式，根据cron表达式确定定时规则
@Scheduled(cron="0/5 * * * * ? ") //每5秒执行一次
public void testCron() {
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
logger.info(sdf.format(new Date())+"*********每5秒执行一次");
}
}
- 存在问题
后来发现个问题，通过同时测试几个任务发现，所有的任务都是在同一个线程池中的同一个线程来完成的。在实际开发过程中，我们当然不希望所有的任务都运行在一个线程中。
- 解决方案
那么，怎么设计成多线程实现并发呢？在网上看到过这样的解决方案。通过ScheduleConfig配置文件实现SchedulingConfigurer接口，并重写setSchedulerfang方法，我们尝试着配置了一下。
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
}
}
- 其他
@Scheduled所支持的参数：
1.cron：cron表达式，指定任务在特定时间执行；
2.fixedDelay：表示上一次任务执行完成后多久再次执行，参数类型为long，单位ms；
3.fixedDelayString：与fixedDelay含义一样，只是参数类型变为String；
4.fixedRate：表示按一定的频率执行任务，参数类型为long，单位ms；
5.fixedRateString: 与fixedRate的含义一样，只是将参数类型变为String；
6.initialDelay：表示延迟多久再第一次执行任务，参数类型为long，单位ms；
7.initialDelayString：与initialDelay的含义一样，只是将参数类型变为String；
8.zone：时区，默认为当前时区，一般没有用到。
