@Scheduled阻塞导致未执行生效-阿里云开发者社区

@Scheduled阻塞导致未执行生效

2023-11-14 39

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： @Scheduled阻塞导致未执行生效

任务【1】

@Component
public class Test01 {
    // 每秒执行一次
    @Scheduled(cron = "0/1 * * * * ? ")
    public void test() {
        // 时分秒
        String nowTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm:ss"));
        // 日志打印
        System.out.println(nowTime + "   任务【1】执行  线程:" + Thread.currentThread().getName());
    }
}
• 11

任务【2】

@Component
public class Test02 {
    // 每5秒执行一次
    @Scheduled(cron = "0/5 * * * * ? ")
    public void test() {
        String nowTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm:ss"));
        System.out.println(nowTime + "   任务【2】执行  线程:" + Thread.currentThread().getName());
        try {
            // 模拟耗时任务，阻塞2s
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

运行
原因

由程序运行后的打印结果可以发现两个任务均是使用的同一线程。
任务【1】应该是每秒执行一次的，但是执行时间上可以发现，任务【1】的执行时间不是连续的，这就说明有时间点是任务【1】没有执行的，而这些时间点恰好任务【2】正在执行中，单线程的原因线程此时阻塞，从而导致这些时间点任务【1】没有执行。

解决添加@Async注解或者使用自定义线程池执行任务在上面的任务【1】和任务【2】的@Scheduled注解上面添加一个注解@Async即可

多线程执行定时任务

注意：对@Async进行自定义配置，内部也是通过创建ThreadPoolExecutor线程池来执行。

全局配置：实现SchedulingConfigurer接口

@Configuration
public class ScheduledConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        // 自定义调度器，设置为一个支持定时及周期性的任务执行的线程池，这里初始3个线程
        scheduledTaskRegistrar.setScheduler(Executors.newScheduledThreadPool(3));
    }
}