@Scheduled注解不能同时执行多个定时任务的解决方案

2024-04-02 19:04:59 607人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录@Scheduled注解不能同时执行多个定时任务@Scheduled同时执行多个定时任务所导致的并发问题@Scheduled的执行顺序@Scheduled同步控制定时任务的执行顺

@Scheduled注解不能同时执行多个定时任务

最近在使用定时任务的时候发现，自己写的定时任务没有执行，后来查了上网查了一下，才知道@Scheduled注解的定时任务是单线程的，同一时间段内只能执行一个定时任务，其它定时任务不执行。

需要配置@Scheduled多线程支持，才能实现同一时间段内，执行多个定时任务。

一般情况下面两个定时任务只会执行第一个定时任务，第二个定时任务不会执行。


    @Scheduled(cron = "0 0 22 * * ?")
    public void test() {
 
        for (int i = 0; i < 20; i++) {
            try {
                Thread.sleep(1000 * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("=======================测试定时任务执行1=======================");
        }
    }
 
    
    @Scheduled(cron = "0 10 22 * * ?")
    public void test2() {
 
        for (int i = 0; i < 20; i++) {
            try {
                Thread.sleep(1000 * 10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("=======================测试定时任务执行2=======================");
        }
    }

要解决上诉问题，就需要配置 @Scheduled多线程支持，添加一个配置类，代码如下：


@Configuration
public class ScheduleConfig implements SchedulinGConfigurer {
 
    @Override
    public void configureTasks(ScheduledTaskReGIStrar taskRegistrar) {
 
        Method[] methods = Job.class.getMethods();
        int defaultPoolSize = 3;
        int corePoolSize = 0;
 
        if (!CollectionUtils.isEmpty(Arrays.asList(methods))) {
 
            for (Method method : methods) {
 
                Scheduled annotation = method.getAnnotation(Scheduled.class);
 
                if (annotation != null) {
 
                    corePoolSize++;
                }
            }
            if (defaultPoolSize > corePoolSize) {
 
                corePoolSize = defaultPoolSize;
            }
 
            taskRegistrar.setScheduler(Executors.newScheduledThreadPool(corePoolSize));
        }
    }
}

@Scheduled同时执行多个定时任务所导致的并发问题

@Scheduled的执行顺序

@Scheduled注解会在默认情况下以单线程的方式执行定时任务。

这个“单线程”指两个方面：

如果一个定时任务执行时间大于其任务间隔时间，那么下一次将会等待上一次执行结束后再继续执行。
如果多个定时任务在同一时刻执行，任务会依次执行。

那么这种效果肯定不是我们想要的，为了使@Scheduled效率更高，我们可以通过两种方法将定时任务变成多线程执行：

1、在启动类中配置TaskScheduler线程池大小

@Bean
public TaskScheduler taskScheduler() {
    ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    taskScheduler.setPoolSize(50);
    return taskScheduler;
}

2、利用Spring提供的@Async注解和@EnableAsync注解

@Component
@EnableAsync
public class TimedTask{
    @Async
    @Scheduled(cron = "0 0/1 * * * ?")//每一分钟执行一次
    public void taskA() {
        //执行你的业务逻辑
    }
    
    @Async
    @Scheduled(cron = "0 0/1 * * * ?")//每一分钟执行一次
    public void taskB() {
        //执行你的业务逻辑
    }

通过以上方式，定时任务将会以多线程的方式开始执行，减小了程序耦合度，提升运行效率。

@Scheduled同步

定时任务在同一时刻开始执行有两种情况：

多个任务的间隔时间相同，如都是1分钟执行一次，那么每一分钟，这些任务都会一起执行。
多个任务的间隔时间不同，但有重合的时刻。如一个任务每天零点执行，另一个任务每一分钟执行，那么这两个任务在零点的时刻会一起执行。

由于任务都是异步的，如果多个任务同时操作同一资源，那么必然会导致错误。

这个时候可以给任务加锁，保证任务互不干扰，拥有在同一时刻执行的线程安全：

@Component
@EnableAsync
public class TimedTask{

    private Object lock = new Object();
    
    @Async
    @Scheduled(cron = "0 0 0 * * ?")//每天零点执行
    public void taskA() {
        synchronized(lock){
               //执行你的业务逻辑
        }
    }
    
    @Async
    @Scheduled(cron = "0 0/1 * * * ?")//每一分钟执行一次
    public void taskB() {
        synchronized(lock){
               //执行你的业务逻辑
        }
    }