SpringBoot自定义线程池,执行定时任务方式

@SpringBootApplication
@EnableScheduling
public class LogaopApplication {

    public static void main(String[] args) {
        SpringApplication.run(LogaopApplication.class, args);
    }

}

@Service
@Slf4j
@Component
public class ScheduTestServiceImpl implements ScheduTestService {

    @Autowired
    private ScheduJobDao scheduJobDao;

    @Scheduled(cron = "*/1 * * * * ?") // 一秒执行一次
    @Override
    public void taskTest() throws InterruptedException {
        System.out.println("测试定时任务------");
    }

@Service
@Slf4j
@Component
public class ScheduTestServiceImpl implements ScheduTestService {

    @Autowired
    private ScheduJobDao scheduJobDao;

    @Scheduled(cron = "*/1 * * * * ?")
    @Override
    public void taskTest() throws InterruptedException {
        long timeStamp1 = System.currentTimeMillis();
        Thread.sleep(1000*10);
        System.out.println("测试定时任务1------");
        long timeStamp2 = System.currentTimeMillis();
        log.info("阻塞市时长：{}",timeStamp2-timeStamp1);
    }
    @Scheduled(cron = "*/1 * * * * ?")
    @Override
    public void taskTest2() throws InterruptedException {
        System.out.println("测试定时任务2------");
    }

package com.qty.logaop.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;

@Configuration
@EnableAsync
public class ScheduThreadPool {
    @Value("${async.executor.thread.core_pool_size}")//从配置文件中获取配置项
    private int corePoolSize;
    @Value("${async.executor.thread.max_pool_size}")
    private int maxPoolSize;
    @Value("${async.executor.thread.queue_capacity}")
    private int queueCapacity;
    @Value("${async.executor.thread.name.prefix}")
    private String namePrefix;

    /**
     * 自定义线程池配置类。
     * 不要命名为 taskScheduler，与spring框架的bean重名。
     * @return
     */
    @Bean(name = "asyncServiceExecutor")
    public Executor asyncServiceExecutor() {
        //阿里巴巴编程规范：线程池不允许使用 Executors 去创建，而是通过 ThreadPoolExecutor 的方式，这样的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。

        //SpringBoot项目，可使用Spring提供的对 ThreadPoolExecutor 封装的线程池 ThreadPoolTaskExecutor：
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//        ThreadPoolTaskExecutor executor = new MyThreadPoolTaskExecutor();//自定义ThreadPoolTaskExecutor，会打印线程池情况
        //配置核心线程数
        executor.setCorePoolSize(corePoolSize);
        //配置最大线程数
        executor.setMaxPoolSize(maxPoolSize);
        //配置队列大小
        executor.setQueueCapacity(queueCapacity);
        //配置线程池中的线程的名称前缀
        executor.setThreadNamePrefix(namePrefix);
        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
        //     1、CallerRunsPolicy：不在新线程中执行任务，而是由调用者所在的线程来执行。
        //        "该策略既不会抛弃任务，也不会抛出异常，而是将任务回推到调用者。"顾名思义，在饱和的情况下，调用者会执行该任务（而不是由多线程执行）
        //     2、AbortPolicy：拒绝策略，直接拒绝抛出异常
        //     3、。。。
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //执行初始化
        executor.initialize();
        return executor;
    }

}

    @Scheduled(cron = "*/10 * * * * ?")
    @Async("asyncServiceExecutor")
    @Override
    public void taskTest() throws InterruptedException {
        long timeStamp1 = System.currentTimeMillis();
        Thread.sleep(1000*100);
        System.out.println("测试定时任务1------");
        long timeStamp2 = System.currentTimeMillis();
        log.info("阻塞市时长：{}",timeStamp2-timeStamp1);
    }
    @Scheduled(cron = "*/10 * * * * ?")
    @Async("asyncServiceExecutor")
    @Override
    public void taskTest2() throws InterruptedException {
        System.out.println("测试定时任务2------");
    }