package com.***.springtask;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
@Slf4j
@EnableAsync //開啟異步支持
@EnableScheduling //開啟定時任務(wù)支持
public class ScheduledTask {
    int i = 1;
    //@Scheduled(fixedRate = 5000, initialDelay = 15*1000)
    public void task1(){
//        i++;
//        if(i > 5){
//            ThreadUtil.safeSleep(8*1000);
//        }
        log.debug("task1執(zhí)行了{(lán)}次，{}",i,Thread.currentThread().getId());
    }
    @Scheduled(cron = "0/5 * * * * ?")
    @Async("asyncScheduledPool")
    public void task2(){
        // ThreadUtil.safeSleep(8*1000);
        log.debug("task2執(zhí)行了，{}",Thread.currentThread().getId());
    }
}

package com.***.config;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
@Component
public class ExecutorConfig {
    //定義核心線程數(shù)
    public static final  int CORE_POOL_SIZE = 10;
    // 最大線程數(shù)
    public static final  int MAX_POOL_SIZE = 20;
    // 任務(wù)隊列容量大小
    public static final  int QUEUE_MAX_COUNT = 100;
    @Bean("asyncScheduledPool")
    public Executor asyncScheduledPool(){
        //自定義線程池
        ThreadPoolTaskExecutor threadPoolExecutor = new ThreadPoolTaskExecutor();
        //設(shè)置核心線程數(shù)
        threadPoolExecutor.setCorePoolSize(CORE_POOL_SIZE);
        //設(shè)置最大線程數(shù) ： 長工 +  臨時工
        threadPoolExecutor.setMaxPoolSize(MAX_POOL_SIZE);
        //設(shè)置任務(wù)隊列容量大小
        threadPoolExecutor.setQueueCapacity(QUEUE_MAX_COUNT);
        //設(shè)置線程的名稱前綴
        threadPoolExecutor.setThreadNamePrefix("myTask-");
        //設(shè)置拒絕策略
        threadPoolExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        return  threadPoolExecutor;
    }
}

@Scheduled(fixedDelay = 4000) 

@Scheduled(fixedRate = 10000) 

@Scheduled(initialDelay=1000, fixedRate=5000) //第一次延遲1秒后執(zhí)行，之后按fixedRate的規(guī)則每5秒執(zhí)行一次