springboot + @Scheduled 多任务并发

问题

@Scheduled默认为单线程，开启多个任务时，任务的执行时机会受上一个任务执行时间的影响。

@Component
public class ScheduledTasks {
    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd  HH:mm:ss");

    @Scheduled(fixedDelay = 1000)
    public void first() throws InterruptedException {
        System.out.println("第一个定时任务开始 : " + sdf.format(new Date()) + "\r\n线程 : " + Thread.currentThread().getName());
        System.out.println();
        Thread.sleep(1000 * 5); //模拟第一个任务执行的时间
    }

    @Scheduled(fixedDelay = 1000)
    public void second() {
        System.out.println("第二个定时任务开始 : " + sdf.format(new Date()) + "\r\n线程 : " + Thread.currentThread().getName());
        System.out.println();
    }
}

测试.png

解决方法

在task上加@EnableAsync注解，在任务方法上加@Async注解

@Component
@EnableAsync
public class ScheduledTasks {
    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd  HH:mm;ss");

    @Async
    @Scheduled(fixedDelay = 1000)
    public void first() throws InterruptedException {
        System.out.println("第一个定时任务开始 : " + sdf.format(new Date()) + "\r\n线程 : " + Thread.currentThread().getName());
        System.out.println();
        Thread.sleep(1000 * 5);
    }

    @Async
    @Scheduled(fixedDelay = 1000)
    public void second() {
        System.out.println("第二个定时任务开始 : " + sdf.format(new Date()) + "\r\n线程 : " + Thread.currentThread().getName());
        System.out.println();
    }
}

测试.png

另外，由于开启了多线程，第一个任务的执行时机也不受其本身执行时间的限制，需要注意数据幂等性。

解决方法2

/**
* @author YuanChong
* @create 2019-06-20 14:39
* @desc
*/
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {

   @Autowired
   private Executor executor;

   private final ThreadFactory threadFactory = new BasicThreadFactory.Builder().namingPattern("hualala-scheduled-task-%d").build();

   @Override
   public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
       taskRegistrar.setScheduler(executor);
   }

   @Bean(destroyMethod = "shutdown")
   public Executor taskExecutor() {
       return Executors.newScheduledThreadPool(8, threadFactory);
   }
}

这种方式的好处在于单任务自己是串行，任务与任务之间是并行。

@Scheduled属性

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(Schedules.class)
public @interface Scheduled {
    String cron() default "";

    String zone() default "";

    long fixedDelay() default -1L;

    String fixedDelayString() default "";

    long fixedRate() default -1L;

    String fixedRateString() default "";

    long initialDelay() default -1L;

    String initialDelayString() default "";
}

单线程下：

• cron每一次执行完成后，再遇到给定的规则时间点上触发。
• fixedDelay受上一次执行时间的影响，再间隔设置时间后执行。
• fixedRate安装固定的速率执行，如果一段时间内任务阻塞，会积攒任务次数，在恢复时一次性执行完成。

image.png

另，initialDelay属性可同时配合上面属性使用，用于初次执行前等待的时间。