SpringBoot 定时任务Schedule，异步任务Async

心已赠人 2022-09-12 03:45 327阅读 0赞

### 目录 ###

*   *   *  定时任务Schedule
         *  异步任务Async
         *  cron表达式

spring自带了定时任务、异步任务，springboot中自然也包含了进来，此处主要介绍在springboot中的使用。

定时任务、异步任务是spring|spring自带的，不需要额外添加依赖。

### 定时任务Schedule ###

1、引导类上加 @EnableScheduling

2、yml中配置定时任务的线程池

spring:
      task:
        scheduling:
          pool:
            #定时任务线程池中的线程数，默认值1
            size: 10

一个线程执行一个定时任务，如果线程数不够，会出现部分定时任务没有可用线程来执行的情况。

springboot的定时任务、异步任务都是使用单独的线程池，如果公司有线程池使用规范或觉得内置的线程池不满足需求，可以使用自定义的线程池。

3、编写定时任务

通常会把定时|异步任务抽出来，统一放在单独的包、类中，方便维护

@Component  //放到容器中
    public class XxxTask { 
    
        @Scheduled(fixedRate = 5000)  //指定执行时间。每5000ms执行1次，间隔是距上次执行开始
        public void task1(){ 
    		//要执行的代码
        }
    
        @Scheduled(fixedDelay = 5000) //每5000ms执行1次，间隔是距上次执行结束
        public void task2(){ 
    		//要执行的代码
        }
    
    	@Scheduled(fixedRateString = "5000")  //fixedRateString、fixedDelayString 分别对应以上2种，只是把值写成字符串形式
        public void task3(){ 
    		//要执行的代码
        }
    
    	@Scheduled(cron = "0 0/10 * * * ?")  //使用cron表达式指定
        public void task4(){ 
    		//要执行的代码
        }
        
    }

### 异步任务Async ###

异步任务可分为2类

*  不需要返回数据：比如处理日志、发送邮件、短信…
 *  需要返回数据：比如用户支付订单要校验库存、用户余额、风控…都没有问题才允许支付订单

异步任务都是启动一条新线程来执行，不阻塞当前线程，可以提高效率。

1、引导类上加 @EnableAsync

2、yml中配置异步任务的线程池

spring:
      task:
        execution:
          #线程名称前缀，默认task-
          thread-name-prefix: async-task-thread-
          #异步线程池配置
          pool:
            #默认值 8
            core-size: 6
            #默认值 Integer.MAX_VALUE
            max-size: 20
            #异步任务队列的容量，默认值 Integer.MAX_VALUE
            queue-capacity: 300

3、编写异步任务

一个异步任务对应一个方法，所以又叫做异步方法

@Component  //放到容器中
    @Async  //将类中的方法都标识为异步方法。如果不需要标注全部方法，可以标在方法上
    public class XxxAsyncTask { 
    
        //不需要返回结果的
        public void task1(){ 
            //......
        }
    
        //需要返回结果的，泛型指定要返回的数据类型
        public Future<String> task2(){ 
            //......
            //参数是要返回的数据
            return new AsyncResult<>("success");
        }
    
        public Future<String> task3(){ 
            //......
            return new AsyncResult<>("fail");
        }
    
    }

注意点

*  异步任务会作为 Future 提交给线程池执行，所以异步任务的返回值只能是 void 或 Future
 *  异步任务不能使用 private 或 static 修饰，不然在线程池中调用不了
 *  异步任务不能与调用方在同一个类中，通常是把异步任务写在单独的包、类中，方便维护

4、使用异步任务

@Service
    public class XxxService { 
    
        @Autowired
        private XxxAsyncTask xxxAsyncTask;
    
        public void xxx() { 
            //......
    
            //都是启动新线程来执行task
            xxxAsyncTask.task1();
            Future<String> task2 = xxxAsyncTask.task2();
            Future<String> task3 = xxxAsyncTask.task3();
    
            //...... //当前线程继续往下执行
    
            //当前线程需要使用异步任务的返回结果时，使用get()阻塞当前线程等待异步任务执行完毕
            try { 
            	//能指定超时时间的方法都尽量指定超时时间，避免发生异常时一直阻塞线程
                String r2 = task2.get(1, TimeUnit.MINUTES);
                String r3 = task3.get(1, TimeUnit.MINUTES);
            } catch (ExecutionException e) { 
                e.printStackTrace();
            } catch (InterruptedException e) { 
                e.printStackTrace();
            } catch (TimeoutException e) { 
                e.printStackTrace();
            }
    
            //...... //当前线程继续往下执行
        }
    
    }

### cron表达式 ###

一共7个字段，依次是

*  second：0-59
 *  minute：0-59
 *  hour：0-23
 *  day of month：1-31
 *  month：1-12
 *  day of week：1-7
 *  year：1970-2099

前6个必填，第7个选填、可以缺省。

使用示例

# ？表示不关心该字段的值，用于第六个(day of week）字段
    # 一般前面写0，后面写*，*表示任意值
    
    
    #直接写数字表示在指定时间执行。如果年月日时分秒都写死，则只在指定时间执行一次
    0 0 10 * * ?   # 每天10点执行1次
    0 0 0 1 * ?  #每月1号凌晨执行1次
    
    
    # */n 表示每隔n执行1次，也可以写成0/n
    0 0 */2 * * ?  #每隔2小时执行1次
    
    
    # -表示区间
    0 0 10-14 * * ?   # 每天的10、11、12、13、14点各执行1次
    
    
    # ，表示或者
    0 0 9,15,21 * * ?  #每天9点、15点、21点各执行1次