分布式调度器之Spring Task 的使用详解

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 //开启定时任务支持
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执行了{}次，{}",i,Thread.currentThread().getId());
    }
    @Scheduled(cron = "0/5 * * * * ?")
    @Async("asyncScheduledPool")
    public void task2(){
        // ThreadUtil.safeSleep(8*1000);
        log.debug("task2执行了，{}",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 {
    //定义核心线程数
    public static final  int CORE_POOL_SIZE = 10;
    // 最大线程数
    public static final  int MAX_POOL_SIZE = 20;
    // 任务队列容量大小
    public static final  int QUEUE_MAX_COUNT = 100;
    @Bean("asyncScheduledPool")
    public Executor asyncScheduledPool(){
        //自定义线程池
        ThreadPoolTaskExecutor threadPoolExecutor = new ThreadPoolTaskExecutor();
        //设置核心线程数
        threadPoolExecutor.setCorePoolSize(CORE_POOL_SIZE);
        //设置最大线程数 ： 长工 +  临时工
        threadPoolExecutor.setMaxPoolSize(MAX_POOL_SIZE);
        //设置任务队列容量大小
        threadPoolExecutor.setQueueCapacity(QUEUE_MAX_COUNT);
        //设置线程的名称前缀
        threadPoolExecutor.setThreadNamePrefix("myTask-");
        //设置拒绝策略
        threadPoolExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        return  threadPoolExecutor;
    }
}

@Scheduled(fixedDelay = 4000) 

@Scheduled(fixedRate = 10000) 

@Scheduled(initialDelay=1000, fixedRate=5000) //第一次延迟1秒后执行，之后按fixedRate的规则每5秒执行一次