@Scheduled(fixedDelay = 5000) //上一次執(zhí)行完畢時(shí)間點(diǎn)之后5秒再執(zhí)行

@Scheduled(fixedDelayString = "5000") //上一次執(zhí)行完畢時(shí)間點(diǎn)之后5秒再執(zhí)行

    @Scheduled(fixedDelayString = "${time.fixedDelay}")
    void testFixedDelayString() {
        System.out.println("Execute at " + System.currentTimeMillis());
    }

@Scheduled(fixedRate = 5000) //上一次開(kāi)始執(zhí)行時(shí)間點(diǎn)之后5秒再執(zhí)行

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

package com.example.demo;

import lombok.extern.slf4j.Slf4j;
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.aop.interceptor.SimpleAsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

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


/**
 * 在用springboot框架做定時(shí)任務(wù)的時(shí)候，大部分情況都是直接通過(guò)@Scheduled注解來(lái)指定定時(shí)任務(wù)的。
 * 但是當(dāng)你有多個(gè)定時(shí)任務(wù)時(shí)，@Scheduled并不一定會(huì)按時(shí)執(zhí)行。
 * 因?yàn)槭褂聾Scheduled的定時(shí)任務(wù)雖然是異步執(zhí)行的，但是，默認(rèn)不同的定時(shí)任務(wù)之間并不是并行的。
 *
 * 當(dāng)未手動(dòng)指定taskScheduler時(shí)，會(huì)通過(guò)Executors.newSingleThreadScheduledExecutor()創(chuàng)建默認(rèn)的單線程線程池，
 * 且該線程池的拒絕策略為AbortPolicy，這種策略在線程池?zé)o可用線程時(shí)丟棄任務(wù)，
 * 并拋出異常RejectedExecutionException。
 *
 */
@Slf4j
@Configuration
@EnableScheduling
@EnableAsync
public class ScheduledConfig implements
        SchedulingConfigurer
//        , AsyncConfigurer
{


    /**
     * ThreadPoolTaskExecutor是一個(gè)專門(mén)用于執(zhí)行任務(wù)的類。
     * ThreadPoolTaskScheduler是一個(gè)專門(mén)用于調(diào)度任務(wù)的類。
     * 一個(gè)ThreadPoolTaskExecutor通過(guò)它的corePoolSize ， maxPoolSize ， keepAliveSeconds和queueCapacity屬性在線程池中提供細(xì)粒度的配置。
     * 諸如ThreadPoolTaskScheduler這樣的調(diào)度器不提供這樣的配置。
     */


    /** 最大線程數(shù) */
    private static final int maxPoolSize = 10;
    /** 線程池名前綴（字符串有長(zhǎng)度限制） */
    private static final String threadNamePrefix = "yu-scheduled-";

    @Bean("asyncExecutorScheduled") // bean的名稱，默認(rèn)為首字母小寫(xiě)的方法名，如果不聲明則會(huì)使用方法名
    public ThreadPoolTaskScheduler asyncExecutorScheduled(){
        ThreadPoolTaskScheduler executor = new ThreadPoolTaskScheduler();
        executor.setPoolSize(maxPoolSize);
        executor.setThreadNamePrefix(threadNamePrefix);
        executor.setAwaitTerminationSeconds(60);
        executor.setWaitForTasksToCompleteOnShutdown(true);
        // 初始化
        executor.initialize();
        return executor;
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setTaskScheduler(this.asyncExecutorScheduled());
    }

//    /**
//     * 處理異步方法調(diào)用時(shí)要使用的實(shí)例
//     * @return
//     */
//    @Override
//    public Executor getAsyncExecutor() {
//        return this.asyncExecutorScheduled();
//    }
//
//    /**
//     * 在使用void返回類型的異步方法執(zhí)行期間拋出異常時(shí)要使用的實(shí)例。
//     * @return
//     */
//    @Override
//    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
//        return new SimpleAsyncUncaughtExceptionHandler();
//    }
}

package com.example.demo;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;

import java.util.concurrent.ScheduledThreadPoolExecutor;


/**
 * scheduled 配置文件的第二種使用  不建議使用
 */
@Slf4j
@Configuration
@EnableScheduling
public class ScheduledConfig2 {



    @Bean
    public ScheduledThreadPoolExecutor scheduledExecutorService() {
        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(10);
        return executor;
    }


}

package com.example.demo.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.Date;

/**
 * @Scehduled 定時(shí)任務(wù)測(cè)試
 */
@Slf4j
@Service
public class ScheduledService {
    /**5
     *測(cè)試
     */
    @Scheduled(cron = "*/5 * * * * *")
    public void testScheduled1(){
        log.info("定時(shí)1：{}",new Date());
    }

    @Scheduled(cron = "*/5 * * * * *")
    public void testScheduled2(){
        log.info("定時(shí)2：{}",new Date());
    }

}