亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

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í)間間隔是通過自己實(shí)現(xiàn)的任務(wù)注冊(cè)到任務(wù)調(diào)度實(shí)現(xiàn)的,并在每次調(diào)度的時(shí)候更改下次調(diào)度時(shí)間間隔,如果任務(wù)阻塞或者掛掉了就不會(huì)再被調(diào)度了,如果設(shè)置時(shí)間過長,到下次調(diào)度就需要等待很長時(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è)簡單實(shí)例,下面說一下基本原理。

動(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è)最后說,先說一下第二個(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ù)開始時(shí)間和結(jié)束時(shí)間和實(shí)際執(zhí)行用時(shí),自己需要實(shí)現(xiàn)這個(gè)nextExecutionTime方法根據(jù)上一次任務(wù)執(zhí)行時(shí)間來返回一個(gè)新的Date時(shí)間,new一個(gè)新的periodicTrigger對(duì)象初始化period時(shí)間間隔為新的時(shí)間間隔用nextExecutionTime方法就可以了根據(jù)上下文時(shí)間返回一個(gè)新的任務(wù)調(diào)度時(shí)間了,但是period的時(shí)間不能太長也不能太短最好設(shè)置一個(gè)區(qū)間,這樣可以避免很多粗心的錯(cuò)誤導(dǎo)致的麻煩,到此完美解決動(dòng)態(tài)設(shè)置任務(wù)調(diào)度時(shí)間間隔功能。

再說一下第一個(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);
    }
}

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

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

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

相關(guān)文章

  • 詳解maven中央倉庫連不上的解決辦法

    詳解maven中央倉庫連不上的解決辦法

    這篇文章主要介紹了詳解maven中央倉庫連不上的解決辦法,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09
  • 深入了解Hadoop如何實(shí)現(xiàn)序列化

    深入了解Hadoop如何實(shí)現(xiàn)序列化

    序列化想必大家都很熟悉了,對(duì)象在進(jìn)行網(wǎng)絡(luò)傳輸過程中,需要序列化之后才能傳輸?shù)娇蛻舳耍蛘呖蛻舳说臄?shù)據(jù)序列化之后送達(dá)到服務(wù)端。本文將為大家介紹Hadoop如何實(shí)現(xiàn)序列化,需要的可以參考一下
    2022-01-01
  • Java數(shù)據(jù)結(jié)構(gòu)實(shí)現(xiàn)二維數(shù)組與稀疏數(shù)組轉(zhuǎn)換詳解

    Java數(shù)據(jù)結(jié)構(gòu)實(shí)現(xiàn)二維數(shù)組與稀疏數(shù)組轉(zhuǎn)換詳解

    稀疏數(shù)組是用于優(yōu)化,壓縮具有以下特點(diǎn)的二維數(shù)組:當(dāng)二維數(shù)組中的元素大部分相同,有意義的數(shù)據(jù)元素較少時(shí),可以使用稀疏數(shù)組進(jìn)行簡化,節(jié)省存儲(chǔ)空間
    2021-10-10
  • Spring Cloud之服務(wù)監(jiān)控turbine的示例

    Spring Cloud之服務(wù)監(jiān)控turbine的示例

    這篇文章主要介紹了Spring Cloud之服務(wù)監(jiān)控turbine的示例,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2018-05-05
  • Java獲取配置文件的值過程解析

    Java獲取配置文件的值過程解析

    這篇文章主要介紹了java獲取配置文件的值過程解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-01-01
  • Spring 面向切面編程AOP實(shí)現(xiàn)詳解

    Spring 面向切面編程AOP實(shí)現(xiàn)詳解

    這篇文章主要介紹了Spring 面向切面編程AOP實(shí)現(xiàn)詳解,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-09-09
  • Java字符串原理分析之String是否可變

    Java字符串原理分析之String是否可變

    當(dāng)我們?cè)谇舐殨r(shí),面試官很喜歡問我們關(guān)于String的一些原理性知識(shí),比如String的不可變性、字符串的內(nèi)存分配等,為了讓大家更好地應(yīng)對(duì)面試,并理解String的底層設(shè)計(jì),接下來會(huì)給大家聊聊String的一些原理,比如String為什么具有不可變性,需要的朋友可以參考下
    2023-05-05
  • 詳解JAVA的控制語句

    詳解JAVA的控制語句

    這篇文章主要介紹了Java中的控制語句,循環(huán)等語句是Java編程中流程控制的基礎(chǔ),需要的朋友可以參考下,希望能夠給你帶來幫助
    2021-11-11
  • 配置Spring4.0注解Cache+Redis緩存的用法

    配置Spring4.0注解Cache+Redis緩存的用法

    本篇文章主要介紹了詳解配置Spring4.0注解Cache+Redis緩存的用法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2017-04-04
  • Dubbo框架線程池使用介紹

    Dubbo框架線程池使用介紹

    當(dāng)我們?cè)谑褂胐ubbo的時(shí)候,是可以通過調(diào)整線程池來達(dá)到調(diào)優(yōu)的效果,我們可以在dubbo:protocol 標(biāo)簽中使用用threadpool屬性選擇自己想要使用的線程池,通過threads屬性配置服務(wù)線程數(shù),queues屬性配置使用的隊(duì)列
    2022-09-09

最新評(píng)論