@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 * * * * ?") // 一秒執(zhí)行一次
    @Override
    public void taskTest() throws InterruptedException {
        System.out.println("測試定時任務(wù)------");
    }

@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("測試定時任務(wù)1------");
        long timeStamp2 = System.currentTimeMillis();
        log.info("阻塞市時長：{}",timeStamp2-timeStamp1);
    }
    @Scheduled(cron = "*/1 * * * * ?")
    @Override
    public void taskTest2() throws InterruptedException {
        System.out.println("測試定時任務(wù)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() {
        //阿里巴巴編程規(guī)范：線程池不允許使用 Executors 去創(chuàng)建，而是通過 ThreadPoolExecutor 的方式，這樣的處理方式讓寫的同學(xué)更加明確線程池的運行規(guī)則，規(guī)避資源耗盡的風(fēng)險。

        //SpringBoot項目，可使用Spring提供的對 ThreadPoolExecutor 封裝的線程池 ThreadPoolTaskExecutor：
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//        ThreadPoolTaskExecutor executor = new MyThreadPoolTaskExecutor();//自定義ThreadPoolTaskExecutor，會打印線程池情況
        //配置核心線程數(shù)
        executor.setCorePoolSize(corePoolSize);
        //配置最大線程數(shù)
        executor.setMaxPoolSize(maxPoolSize);
        //配置隊列大小
        executor.setQueueCapacity(queueCapacity);
        //配置線程池中的線程的名稱前綴
        executor.setThreadNamePrefix(namePrefix);
        // rejection-policy：當(dāng)pool已經(jīng)達到max size的時候，如何處理新任務(wù)
        //     1、CallerRunsPolicy：不在新線程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線程來執(zhí)行。
        //        "該策略既不會拋棄任務(wù)，也不會拋出異常，而是將任務(wù)回推到調(diào)用者。"顧名思義，在飽和的情況下，調(diào)用者會執(zhí)行該任務(wù)（而不是由多線程執(zhí)行）
        //     2、AbortPolicy：拒絕策略，直接拒絕拋出異常
        //     3、。。。
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //執(zhí)行初始化
        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("測試定時任務(wù)1------");
        long timeStamp2 = System.currentTimeMillis();
        log.info("阻塞市時長：{}",timeStamp2-timeStamp1);
    }
    @Scheduled(cron = "*/10 * * * * ?")
    @Async("asyncServiceExecutor")
    @Override
    public void taskTest2() throws InterruptedException {
        System.out.println("測試定時任務(wù)2------");
    }