定时任务@Scheduled 和异步@Async

迈不过友情╰ 2023-10-04 11:51 64阅读 0赞

#### 文章目录 ####

*   *  概述
     *  cron表达式
     *  什么是异步
     *  @Scheduled

### 概述 ###

Spring 3.0 版本之后自带定时任务，提供了`@EnableScheduling`注解和`@Scheduled`注解来实现定时任务功能。

使用SpringBoot创建定时任务非常简单，目前主要有以下三种创建方式：

1、基于注解（`@Scheduled`）  
2、基于接口（`SchedulingConfigurer`） 前者相信大家都很熟悉，但是实际使用中我们往往想从数据库中读取指定时间来动态执行定时任务，这时候基于接口的定时任务就派上用场了。  
3、基于注解设定多线程定时任务

### cron表达式 ###

cron表达式是一个字符串，由6到7个字段组成，用空格分隔。其中前6个字段是必须的，最后一个是可选的。

[cron表达式在线生成][cron]

### 什么是异步 ###

**异步**： 异步调用则是只是发送了调用的指令，调用者无需等待被调用的方法完全执行完毕；而是继续执行下面的流程。例如， 在某个调用中，需要顺序调用 A, B, C三个过程方法；如他们都是同步调用，则需要将他们都顺序执行完毕之后，方算作过程执行完毕； 如B为一个异步的调用方法，则在执行完A之后，**调用B，并不等待B完成**，而是执行开始调用C，待C执行完毕之后，就意味着这个过程执行完毕了。在Java中，一般在处理类似的场景之时，都是基于创建独立的线程去完成相应的异步调用逻辑，通过主线程和不同的业务子线程之间的执行流程，从而在启动独立的线程之后，主线程继续执行而不会产生停滞等待的情况。

### @Scheduled ###

`TaskScheduler`： 任务调度者  
`TaskExecutor` ： 任务执行者

`@EnableScheduling` 开启定时任务功能，方法所在类需要加`@Component`  
`@Scheduled(Cron= "")` 指定执行的时间

@Scheduled(cron = "0/1 * * * * ? ")
        @Override
        public Result ScanUserState() throws InterruptedException {
        
            Thread.sleep(5000);
            System.out.println("执行了");
            return new Result();
        }

定时任务，只有一个线程去执行任务，任务间隔是1000毫秒，执行任务需要5000毫秒，那么任务的执行周期是1000+5000=6000毫秒。就算线程池中有多个线程，也会等那个任务执行完再选取一个线程再次执行任务。

如果同时开启了`@EnableAsync`和使用了`@Async`，如果执行时间大于Cron表达式的时间，则会选取线程池中其他的线程立刻去执行任务，如果没有剩余线程，则会等待有线程空闲出来。

@Configuration
    public class ScheduleConfig implements SchedulingConfigurer,AsyncConfigurer {
        
    
        //并行任务
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar){
        
            TaskScheduler taskScheduler = taskScheduler();
            taskRegistrar.setTaskScheduler(taskScheduler);
        }
    
    
        //并行任务使用策略：多线程处理（配置线程数等）
        @Bean("task1")
        public ThreadPoolTaskScheduler taskScheduler(){
        
            ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
            scheduler.setPoolSize(20);
            scheduler.setThreadNamePrefix("task-");  //设置线程名开头
            scheduler.setAwaitTerminationSeconds(60);
            scheduler.setWaitForTasksToCompleteOnShutdown(true);
            return scheduler;
        }
    
        //异步任务
        public Executor getAsyncExecutor(){
        
            Executor executor = taskScheduler();
            return executor;
        }
    
        //异步任务 异常处理
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler(){
        
            return new SimpleAsyncUncaughtExceptionHandler();
        }
    }

@Async("task1")
        @Scheduled(cron = "0/1 * * * * ? ")
        @Override
        public Result ScanUserState() throws InterruptedException {
        
            Thread.sleep(5000);
            System.out.println("执行了");
            return new Result();
            // return LoginDao.ScanUserState();
        }

[cron]: http://cron.ciding.cc/