package com.test.hello.task;

import com.test.hello.service.TestEntityService;
import com.test.hello.service.TestOneEntityService;
import com.test.hello.service.TestTwoEntityService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.TimeZone;

@Slf4j
@Component
public class TestTask {

    //全局修改時(shí)區(qū)，設(shè)置JVM的默認(rèn)時(shí)區(qū)，影響整個(gè) Java 虛擬機(jī)中所有涉及日期和時(shí)間的操作所使用的時(shí)區(qū)。
    //在Java中，通過(guò) TimeZone.setDefault() 方法可以實(shí)現(xiàn)對(duì) JVM 默認(rèn)時(shí)區(qū)的修改。
    static {
        TimeZone.setDefault(TimeZone.getTimeZone("GMT+8"));
    }

    //顯示指定時(shí)區(qū)，不影響全局
    // 顯式指定使用的時(shí)區(qū)為 GMT+8
    ZoneId zoneId = ZoneId.of("GMT+8");

    // 獲取當(dāng)前時(shí)間
    LocalDateTime currentTime = LocalDateTime.now(zoneId);

    // 格式化日期時(shí)間
    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
    String formattedTime = currentTime.format(formatter);



    @Autowired
    private TestEntityService testEntityService;

    @Autowired
    private TestOneEntityService testOneEntityService;

    @Autowired
    private TestTwoEntityService testTwoEntityService;


    /**
     * 每天的00:00:00執(zhí)行任務(wù)
     */
    @Scheduled(cron = "0 0 0 * * *")
    public void scheduled() {
        log.info("=====>>>>>使用cron  {}", testEntityService.countSum());
    }

    @Scheduled(cron = "0 0/1 * * * ?")
    public void scheduledStatisticsOnAboardNum() {
        log.info("=====>>>>>統(tǒng)計(jì): 使用cron  {}", testEntityService.countSum());
        log.info("=====>>>>>)統(tǒng)計(jì): 使用cron  {}", testOneEntityService.countSum());
        log.info("=====>>>>>合計(jì)統(tǒng)計(jì): 使用cron  {}", testTwoEntityService.countSum());
    }


}

package com.test.stats.schedule;

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;


@Component
@Slf4j
public class TestSchedule {

    //定時(shí)器表達(dá)式配置在nacos中
    @Scheduled(cron = "${testSchedule.oneCron}")
    //單獨(dú)配置線(xiàn)程池
    @Async("PoolThread")
    public void testScheduled() {
      //定時(shí)器執(zhí)行的邏輯代碼
    }
}

package com.test.hello.config;


import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ThreadPoolExecutor;

@Configuration
public class ThreadPoolTaskConfig {


    //這里的命名可以在報(bào)錯(cuò)的時(shí)候清楚是哪個(gè)線(xiàn)程報(bào)錯(cuò)了
    @Bean("PoolThread")
    public ThreadPoolTaskExecutor threadPoolWorkTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //線(xiàn)程池創(chuàng)建的核心線(xiàn)程數(shù)，線(xiàn)程池維護(hù)線(xiàn)程的最少數(shù)量，即使沒(méi)有任務(wù)需要執(zhí)行，也會(huì)一直存活
        executor.setCorePoolSize(8);
        //如果設(shè)置allowCoreThreadTimeout=true（默認(rèn)false）時(shí)，核心線(xiàn)程會(huì)超時(shí)關(guān)閉
        //executor.setAllowCoreThreadTimeOut(true);
        //阻塞隊(duì)列 當(dāng)核心線(xiàn)程數(shù)達(dá)到最大時(shí)，新任務(wù)會(huì)放在隊(duì)列中排隊(duì)等待執(zhí)行
        executor.setQueueCapacity(124);
        //最大線(xiàn)程池?cái)?shù)量，當(dāng)線(xiàn)程數(shù)>=corePoolSize，且任務(wù)隊(duì)列已滿(mǎn)時(shí)。線(xiàn)程池會(huì)創(chuàng)建新線(xiàn)程來(lái)處理任
        //任務(wù)隊(duì)列已滿(mǎn)時(shí), 且當(dāng)線(xiàn)程數(shù)=maxPoolSize，，線(xiàn)程池會(huì)拒絕處理任務(wù)而拋出異常
        executor.setMaxPoolSize(64);
        //當(dāng)線(xiàn)程空閑時(shí)間達(dá)到keepAliveTime時(shí)，線(xiàn)程會(huì)退出，直到線(xiàn)程數(shù)量=corePoolSize
        //允許線(xiàn)程空閑時(shí)間30秒，當(dāng)maxPoolSize的線(xiàn)程在空閑時(shí)間到達(dá)的時(shí)候銷(xiāo)毀
        //如果allowCoreThreadTimeout=true，則會(huì)直到線(xiàn)程數(shù)量=0
        executor.setKeepAliveSeconds(30);
        //spring 提供的 ThreadPoolTaskExecutor 線(xiàn)程池，是有setThreadNamePrefix() 方法的。
        //jdk 提供的ThreadPoolExecutor 線(xiàn)程池是沒(méi)有 setThreadNamePrefix() 方法的
        executor.setThreadNamePrefix("PoolThread");
        // rejection-policy：拒絕策略：當(dāng)線(xiàn)程數(shù)已經(jīng)達(dá)到maxSize的時(shí)候，如何處理新任務(wù)
        // CallerRunsPolicy()：交由調(diào)用方線(xiàn)程運(yùn)行，比如 main 線(xiàn)程；如果添加到線(xiàn)程池失敗，那么主線(xiàn)程會(huì)自己去執(zhí)行該任務(wù)，不會(huì)等待線(xiàn)程池中的線(xiàn)程去執(zhí)行
        // AbortPolicy()：該策略是線(xiàn)程池的默認(rèn)策略，如果線(xiàn)程池隊(duì)列滿(mǎn)了丟掉這個(gè)任務(wù)并且拋出RejectedExecutionException異常。
        // DiscardPolicy()：如果線(xiàn)程池隊(duì)列滿(mǎn)了，會(huì)直接丟掉這個(gè)任務(wù)并且不會(huì)有任何異常
        // DiscardOldestPolicy()：丟棄隊(duì)列中最老的任務(wù)，隊(duì)列滿(mǎn)了，會(huì)將最早進(jìn)入隊(duì)列的任務(wù)刪掉騰出空間，再?lài)L試加入隊(duì)列
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
        executor.initialize();
        return executor;
    }

}