>前言

==注：
大家好我是妈妈的好大儿，
笔者联系方式
QQ：3302254385
微信：yxc3302254385
交个朋友！==
创作不易，三连十分感谢！！！

>简介

定时任务是大家项目里比较常用的功能了，但是网上的教程比较杂也比较坑，只能说是基本使用没有问题，极端情况下也会出现很多的问题！！！学习就是不断循序渐进的不断深入，此篇不讨论定时任务的基本使用，主要是进阶，今天笔者将会以翻阅源码的方式层层递进给大家一一解析！！！

>问题说明

**先给大家看一个案列，SpirngBoot的定时任务默认是单线程执行的！！！**
这里创建了3个定时任务，都是每隔5秒执行一次，每个任务在执行的期间都会休眠5秒！！查看结果我们会发现，只有当上一个定时任务执行完毕，才会执行下一个定时任务，所以它并不是并行执行的！！！如果我们有多个定时任务需要在同一刻执行，上一个任务没有执行完，就会下一个任务无法执行，导致出现服务上的问题！！！

~~~java
/**
 * @Author: Joker-CC
 * @Date 2021/06/18 16:42
 * @Description:
 * @Version: 1.0
 */
@Component
public class TestJob {

@Scheduled(cron = "0/5 * * * * ?")
    public void test1() throws InterruptedException {
        System.out.println("执行任务1--->开始时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
        Thread.sleep(5000L);
        System.out.println("执行任务1");
        System.out.println("执行任务1--->结束时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
    }

@Scheduled(cron = "0/5 * * * * ?")
    public void test2()throws InterruptedException {
        System.out.println("执行任务2--->开始时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
        Thread.sleep(5000L);
        System.out.println("执行任务2");
        System.out.println("执行任务2--->结束时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
    }
    
    @Scheduled(cron = "0/5 * * * * ?")
    public void test3()throws InterruptedException {
        System.out.println("执行任务3--->开始时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
        Thread.sleep(5000L);
        System.out.println("执行任务3");
        System.out.println("执行任务3--->结束时间"+ SuperUtil.convertDateStr(System.currentTimeMillis()));
    }

}

~~~
==背景不是重点!!!!==
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210618174022349.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
>原理分析

为什么会出现这种问题呢！！！我们点开@EnableScheduled注解的源码！！
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210621152745372.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
来翻译一下源码！！！
~~~java
	/**
	默认情况下，将搜索关联的调度程序定义：上下文中唯一的org.springframework.scheduling.TaskScheduler bean，
	或否则名为“taskScheduler”的TaskScheduler bean； 还将java.util.concurrent.ScheduledExecutorService bean 执行相同的查找。 
	如果两者都无法解析，则会在注册器中创建和使用本地单线程默认调度程序。
	当需要更多控制时， @Configuration类可以实现SchedulingConfigurer 。 这允许访问底层ScheduledTaskRegistrar实例。 
	例如，以下示例演示如何自定义用于执行计划任务的Executor ：
	*/
   @Configuration
   @EnableScheduling
   public class AppConfig implements SchedulingConfigurer {
  
       @Override
       public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
           taskRegistrar.setScheduler(taskExecutor());
       }
  
       @Bean(destroyMethod="shutdown")
       public Executor taskExecutor() {
           return Executors.newScheduledThreadPool(100);
       }
   }
   
   //注意上面例子中@Bean(destroyMethod="shutdown") 。 这确保了当 Spring 应用程序上下文本身关闭时任务执行器被正确关闭。

~~~
==为了避免，单线程执行定时任务，源码里提到，我们去实现SchedulingConfigurer==
~~~java
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import java.util.concurrent.*;

/**
 * @Author: Joker-CC
 * @Date 2021/06/18 16:57
 * @Description:
 * @Version: 1.0
 */
@Configuration
public class JobConfig implements SchedulingConfigurer {

@Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //设置TaskScheduler以注册计划任务，或设置ScheduledExecutorService包装为TaskScheduler
        taskRegistrar.setScheduler(taskExecutor());
    }

@Bean(destroyMethod="shutdown")
    public Executor taskExecutor() {
        //创建定时队列 参数线程池的核心线程数
        return Executors.newScheduledThreadPool(1);
    }

}
~~~

然后我们再去查看，Executors.newScheduledThreadPool(1)；
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210621162058816.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210621162403488.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
这里有多少个线程去，去执行定时任务取决于创建定时任务的核心线程数，多余的任务，没有线程去执行，哪怕时间到了也会存在定时队列，等待有可用的线程！！！

>其他方式 使用@Async

还有一些公司会@Async异步任务注解，去实现定时任务的多线程执行，我们来看一下，开启异步任务的注解的源码！！！
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210622105840615.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
大概的中文意思：
~~~java
默认情况下，Spring 将搜索关联的线程池定义：上下文中唯一的org.springframework.core.task.TaskExecutor bean，
或者名为“taskExecutor”的java.util.concurrent.Executor bean。
如果两者都不可解析，则将使用org.springframework.core.task.SimpleAsyncTaskExecutor来处理异步方法调用。
此外，具有void返回类型的带注释的方法不能将任何异常传输回调用者。 默认情况下，仅记录此类未捕获的异常。
要自定义所有这些，请实现AsyncConfigurer并提供：
你自己的Executor通过getAsyncExecutor()方法，和
您自己的AsyncUncaughtExceptionHandler通过getAsyncUncaughtExceptionHandler()方法。
注意： AsyncConfigurer配置类在应用程序上下文引导程序的早期初始化。
如果您需要对其他 bean 的任何依赖，请确保尽可能将它们声明为“懒惰”，以便让它们也通过其他后处理器。
~~~
==言简意赅：主要讲了3点==

1. ==默认使用的**SimpleAsyncTaskExecutor**来处理异步方法调用==
 2. ==需要自定义**实现AsyncConfigurer**接口==
 3. ==异步任务的异常，通过**实现AsyncUncaughtExceptionHandler接口**，获取异常信息==
 4. ==自定义异步任务配置的加载顺序==

那我们看看默认的实现**SimpleAsyncTaskExecutor**是否符合我们的预期！！
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210622112810239.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTkyOTA4Mg==,size_16,color_FFFFFF,t_70)
**源码翻译：**
~~~java
TaskExecutor实现，为每个任务启动一个新线程，异步执行它。
支持通过“concurrencyLimit”bean 属性限制并发线程。 
默认情况下，并发线程数是无限的。
注意：此实现不重用线程！ 考虑使用线程池 TaskExecutor 实现，特别是用于执行大量短期任务
~~~
==线程数是无限的，而且不重用线程！！！所以会导致大量的系统资源浪费！！！所以我们还是自定义更加合适！注（concurrencyLimit属性限制最大并发数，可以在运行时动态更改！！！）==

>实现自定义的异步任务配置

**异步配置类**
~~~java
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;

/**
 * @Author: Joker-CC
 * @Date 2021/06/21 17:43
 * @Description: 配置异步任务
 * @Version: 1.0
 */
@Configuration
@EnableAsync
public class AysnConfig  implements AsyncConfigurer  {

/**
     * 处理异步方法调用时要使用的Executor实例。
     * @return
     */
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //设置 ThreadPoolExecutor 的核心池大小。 默认值为 1(可在运行时修改)
        executor.setCorePoolSize(7);
        //设置 ThreadPoolExecutor 的最大池大小。 默认值为Integer.MAX_VALUE 。(可在运行时修改)
        executor.setMaxPoolSize(42);
        //设置 ThreadPoolExecutor 的 BlockingQueue 的容量。 默认值为Integer.MAX_VALUE >0会创建LinkedBlockingQueue实例；任何其他值都将创建SynchronousQueue实例。
        executor.setQueueCapacity(11);
        //指定用于新创建线程名称的前缀
        executor.setThreadNamePrefix("MyExecutor-");
        //初始化
        executor.initialize();
        return executor;
    }

/**
     * 在具有void返回类型的异步方法执行期间，引发异常时,要使用的AsyncUncaughtExceptionHandler实例
     * @return
     */
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new MyAsyncUncaughtExceptionHandler();
    }

}
~~~
**异步异常处理器**
~~~java
import lombok.extern.slf4j.Slf4j;
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import java.lang.reflect.Method;

/**
 * @Author: Joker-CC
 * @Date 2021/06/21 17:51
 * @Description: 异步任务异常处理器
 * @Version: 1.0
 */
@Slf4j
public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {

/**
     * 处理从异步方法抛出的给定的未捕获异常。
     * @param ex    从异步方法抛出的异常
     * @param method    异步方法
     * @param params    用于调用方法的参数
     */
    @Override
    public void handleUncaughtException(Throwable ex, Method method, Object... params) {
        log.info("错误消息--->"+ex.getMessage()+"错误的方法--->"+method.getName());
    }
}
~~~
此篇博文就到此结束了！！！！一般来说还是根据自己的cpu和业务场景来自定义配置！！！慢慢提升自己，每天进步一点！！！

SpringBoot定时任务，异步任务源码解析，@EnableScheduled注解，@EnableAsync注解分析！！！定时任务和异步任务进阶篇！

总共已有 0 条评论