最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

spring @schedule注解如何動(dòng)態(tài)配置時(shí)間間隔

 更新時(shí)間:2021年11月02日 10:14:31   作者:zpzkitt  
這篇文章主要介紹了spring @schedule注解如何動(dòng)態(tài)配置時(shí)間間隔,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

@schedule注解動(dòng)態(tài)配置時(shí)間間隔

動(dòng)態(tài)配置時(shí)間間隔是通過(guò)自己實(shí)現(xiàn)的任務(wù)注冊(cè)到任務(wù)調(diào)度實(shí)現(xiàn)的,并在每次調(diào)度的時(shí)候更改下次調(diào)度時(shí)間間隔,如果任務(wù)阻塞或者掛掉了就不會(huì)再被調(diào)度了,如果設(shè)置時(shí)間過(guò)長(zhǎng),到下次調(diào)度就需要等待很長(zhǎng)時(shí)間。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.PeriodicTrigger;
import org.springframework.stereotype.Component; 
import java.util.Date; 
 
@Component
@EnableScheduling
public class DynamicScheduleTaskSecond implements SchedulingConfigurer {
    private static final long WEEK_MILLIS = 604800000;
    private static final long MIN_MILLIS = 1000;
    private static long period = 1000;
    static long l = System.currentTimeMillis();
 
    @Autowired
    SetPeriod setPeriod; 
    public static long getPeriod() {
        return period;
    }
 
    public static void setPeriod(long period) {
        DynamicScheduleTaskSecond.period = period;
    }
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask(new Runnable() {
            @Override
            public void run() {
                try {
                    setPeriod.update(period);
                    System.out.println("abc");
                    Long last = System.currentTimeMillis() - l;
                    l = System.currentTimeMillis();
                    System.out.println(last);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                if (period < MIN_MILLIS || period > WEEK_MILLIS)
                    period = MIN_MILLIS;
                PeriodicTrigger periodicTrigger = new PeriodicTrigger(period);
                Date nextExecDate = periodicTrigger.nextExecutionTime(triggerContext);
                return nextExecDate;
            }
        });
    }
}
  
import org.springframework.stereotype.Component; 
@Component
public class SetPeriod { 
    private static Long maxPeriod = 1000l; 
    public void update(Long period) {
        maxPeriod += 1000;
        setScheduleConfig(maxPeriod);
    }
 
    public boolean setScheduleConfig(Long period) {
        DynamicScheduleTaskSecond.setPeriod(period);
        return true;
    }
}

上面是實(shí)現(xiàn)動(dòng)態(tài)調(diào)度的一個(gè)簡(jiǎn)單實(shí)例,下面說(shuō)一下基本原理。

動(dòng)態(tài)調(diào)度功能主要是實(shí)現(xiàn)SchedulingConfigurer函數(shù)式接口,接口中的方法configureTasks的參數(shù)是重點(diǎn)。

@FunctionalInterface
public interface SchedulingConfigurer {
 
 /**
  * Callback allowing a {@link org.springframework.scheduling.TaskScheduler
  * TaskScheduler} and specific {@link org.springframework.scheduling.config.Task Task}
  * instances to be registered against the given the {@link ScheduledTaskRegistrar}.
  * @param taskRegistrar the registrar to be configured.
  */
 void configureTasks(ScheduledTaskRegistrar taskRegistrar); 
}

看名字 ScheduledTaskRegistrar就知道是一個(gè)調(diào)度任務(wù)注冊(cè)類,調(diào)用這個(gè)類的addTriggerTask方法需要兩個(gè)參數(shù)

    public void addTriggerTask(Runnable task, Trigger trigger) {
        this.addTriggerTask(new TriggerTask(task, trigger));
    }

一個(gè)是任務(wù)線程這個(gè)最后說(shuō),先說(shuō)一下第二個(gè)Trigger,這是一個(gè)設(shè)置任務(wù)觸發(fā)時(shí)間的接口,具體的實(shí)現(xiàn)有兩個(gè)類,一個(gè)是CronTrigger對(duì)應(yīng)的就是cron類型的時(shí)間設(shè)置,一個(gè)是PeriodicTrigger對(duì)應(yīng)的就是FixDelay和FixRate兩種方式的時(shí)間設(shè)置,實(shí)例中使用的是后者。

public interface Trigger {
    @Nullable
    Date nextExecutionTime(TriggerContext var1);
}

接口方法參數(shù)是一個(gè)TriggerContext,這個(gè)參數(shù)就是任務(wù)觸發(fā)的上下文,里面保存著上一次任務(wù)開(kāi)始時(shí)間和結(jié)束時(shí)間和實(shí)際執(zhí)行用時(shí),自己需要實(shí)現(xiàn)這個(gè)nextExecutionTime方法根據(jù)上一次任務(wù)執(zhí)行時(shí)間來(lái)返回一個(gè)新的Date時(shí)間,new一個(gè)新的periodicTrigger對(duì)象初始化period時(shí)間間隔為新的時(shí)間間隔用nextExecutionTime方法就可以了根據(jù)上下文時(shí)間返回一個(gè)新的任務(wù)調(diào)度時(shí)間了,但是period的時(shí)間不能太長(zhǎng)也不能太短最好設(shè)置一個(gè)區(qū)間,這樣可以避免很多粗心的錯(cuò)誤導(dǎo)致的麻煩,到此完美解決動(dòng)態(tài)設(shè)置任務(wù)調(diào)度時(shí)間間隔功能。

再說(shuō)一下第一個(gè)線程任務(wù)中的需要做的事,執(zhí)行的任務(wù)需要在其他的具體類中實(shí)現(xiàn),然后在這個(gè)線程中調(diào)用,然后每次在調(diào)度任務(wù)的時(shí)候就要根據(jù)時(shí)間業(yè)務(wù)重新設(shè)置時(shí)間間隔,比如讀配置后改變時(shí)間間隔,也就是調(diào)度和具體的任務(wù)形成一個(gè)環(huán),調(diào)度執(zhí)行具體的任務(wù)后,具體的任務(wù)在設(shè)置調(diào)度的時(shí)間間隔。

spring 注解式Schedule配置定時(shí)任務(wù)

@Component
public class ScheduledTasks {
    @Autowired
    private ActivityService activityService;
//    1000即1s
    @Scheduled(fixedRate = 1000)
    public void reportCurrentTime() {
        System.out.println("當(dāng)前時(shí)間: " + DateUtil.getNow());
        log.info("打印當(dāng)前時(shí)間: {}.", DateUtil.getNow());
    }
    /*每天四點(diǎn)更新一次*/
    @Scheduled(cron = "0 0 4 * * ? ")
    public void updateRankLIstToRedis() {
        /* redis超時(shí)設(shè)置 expire多次設(shè)置會(huì)覆蓋 */
        List<RankInfoDTO> list = activityService.countRankList(ACTIVITY_WEB);
    }
}

很簡(jiǎn)單,要注意的是 設(shè)置時(shí)間間隔有兩種 corn和fixedRate,一種適用于較長(zhǎng)的時(shí)間而且能設(shè)置特定時(shí)間,一種則較短。

cron的話,百度第一個(gè)就是傻瓜式工具網(wǎng)頁(yè),不用怕不會(huì)寫(xiě)。

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • java并發(fā)編程之ThreadLocal詳解

    java并發(fā)編程之ThreadLocal詳解

    在鎖的使用中會(huì)導(dǎo)致運(yùn)行效率降低,ThreadLocal的使用徹底避免對(duì)共享資源的競(jìng)爭(zhēng),同時(shí)又可以不影響效率。本文詳細(xì)講解了ThreadLocal,需要了解的小伙伴可以看一看這篇文章
    2021-08-08
  • Java遞歸和迭代區(qū)別詳細(xì)介紹

    Java遞歸和迭代區(qū)別詳細(xì)介紹

    這篇文章主要給大家介紹了關(guān)于Java中的迭代和遞歸有什么區(qū)別,文中介紹的非常詳細(xì),感興趣的同學(xué)可以參考閱讀
    2023-04-04
  • Java利用EasyExcel實(shí)現(xiàn)合并單元格

    Java利用EasyExcel實(shí)現(xiàn)合并單元格

    在某些業(yè)務(wù)場(chǎng)景中可能會(huì)有合并單元格的需求,本文將詳細(xì)為大家講解Java如何利用EasyExcel實(shí)現(xiàn)合并單元格,感興趣的小伙伴可以了解一下
    2022-06-06
  • java之a(chǎn)ssert關(guān)鍵字用法案例詳解

    java之a(chǎn)ssert關(guān)鍵字用法案例詳解

    這篇文章主要介紹了java之a(chǎn)ssert關(guān)鍵字用法案例詳解,本篇文章通過(guò)簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下
    2021-08-08
  • Java實(shí)現(xiàn)的連續(xù)奇數(shù)(n+2*x)是合數(shù)的算法題暴力算法

    Java實(shí)現(xiàn)的連續(xù)奇數(shù)(n+2*x)是合數(shù)的算法題暴力算法

    這篇文章主要介紹了Java實(shí)現(xiàn)的連續(xù)奇數(shù)(n+2*x)是合數(shù)的算法題暴力算法,本文包含運(yùn)算結(jié)果和實(shí)現(xiàn)代碼,需要的朋友可以參考下
    2014-09-09
  • 實(shí)體類或?qū)ο笮蛄谢瘯r(shí),忽略為空屬性的操作

    實(shí)體類或?qū)ο笮蛄谢瘯r(shí),忽略為空屬性的操作

    這篇文章主要介紹了實(shí)體類或?qū)ο笮蛄谢瘯r(shí),忽略為空屬性的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-06-06
  • mybatis如何使用truncate清空表

    mybatis如何使用truncate清空表

    這篇文章主要介紹了mybatis如何使用truncate清空表,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-03-03
  • 基于Java實(shí)現(xiàn)一個(gè)自己的HTTP瀏覽器

    基于Java實(shí)現(xiàn)一個(gè)自己的HTTP瀏覽器

    這篇文章主要為大家詳細(xì)介紹了如何基于Java實(shí)現(xiàn)一個(gè)自己的HTTP瀏覽器,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-01-01
  • SpringBoot如何使用MyBatisPlus逆向工程自動(dòng)生成代碼

    SpringBoot如何使用MyBatisPlus逆向工程自動(dòng)生成代碼

    本文介紹如何使用SpringBoot、MyBatis-Plus進(jìn)行逆向工程自動(dòng)生成代碼,并結(jié)合Swagger3.0實(shí)現(xiàn)API文檔的自動(dòng)生成和訪問(wèn),通過(guò)詳細(xì)步驟和配置,確保Swagger與SpringBoot版本兼容,并通過(guò)配置文件和測(cè)試類實(shí)現(xiàn)代碼生成和Swagger文檔的訪問(wèn)
    2024-12-12
  • 解決feignclient調(diào)用服務(wù),傳遞的中文數(shù)據(jù)成???問(wèn)題

    解決feignclient調(diào)用服務(wù),傳遞的中文數(shù)據(jù)成???問(wèn)題

    這篇文章主要介紹了解決feignclient調(diào)用服務(wù),傳遞的中文數(shù)據(jù)成???問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-01-01

最新評(píng)論

民乐县| 福建省| 江华| 娄烦县| 清丰县| 兰州市| 泽普县| 都昌县| 巴南区| 高淳县| 安多县| 睢宁县| 原阳县| 呼图壁县| 平陆县| 京山县| 伊金霍洛旗| 瑞安市| 赤壁市| 师宗县| 商洛市| 廊坊市| 曲周县| 祁门县| 武安市| 桑日县| 德庆县| 金乡县| 分宜县| 石景山区| 喀喇沁旗| 靖边县| 襄城县| 阿勒泰市| 广昌县| 盘锦市| 平远县| 唐山市| 孟津县| 玛曲县| 平阳县|