欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

深入了解Java定時器中的Timer的原理

 更新時間:2022年01月11日 14:40:26   作者:小西學(xué)JAVA  
這篇文章主要介紹了Java定時器中的Timer的原理。Timer主要用于Java線程里指定時間或周期運(yùn)行任務(wù),它是線程安全的,但不提供實時性(real-time)保證。接下來就跟隨小編一起深入了解Timer吧

Java在1.3版本引入了Timer工具類,它是一個古老的定時器,搭配TimerTask和TaskQueue一起使用。從Java5開始在并發(fā)包中引入了另一個定時器
ScheduledThreadPoolExecutor,它對Timer做了很多改進(jìn)并提供了更多的工具,可以認(rèn)為是對Timer的取代。

那為什么還要介紹Timer工具類呢?通過了解Timer的功能和它背后的原理,有助于我們更好的對比了解
ScheduledThreadPoolExecutor,同時ScheduledThreadPoolExecutor的一些改進(jìn)思想在我們平時的編碼工作中也可以借鑒。

主要成員變量

Timer中用到的主要是兩個成員變量:

  • TaskQueue:一個按照時間優(yōu)先排序的隊列,這里的時間是每個定時任務(wù)下一次執(zhí)行的毫秒數(shù)(相對于1970年1月1日而言)
  • TimerThread:對TaskQueue里面的定時任務(wù)進(jìn)行編排和觸發(fā)執(zhí)行,它是一個內(nèi)部無限循環(huán)的線程。
//根據(jù)時間進(jìn)行優(yōu)先排序的隊列    
private final TaskQueue queue = new TaskQueue();

//消費(fèi)線程,對queue中的定時任務(wù)進(jìn)行編排和執(zhí)行
private final TimerThread thread = new TimerThread(queue);

//構(gòu)造函數(shù)
public Timer(String name) {
        thread.setName(name);
        thread.start();
}

定時功能

Timer提供了三種定時模式:

  • 一次性任務(wù)
  • 按照固定的延遲執(zhí)行(fixed delay)
  • 按照固定的周期執(zhí)行(fixed rate)

第一種比較好理解,即任務(wù)只執(zhí)行一次;針對第一種,Timer提供了以下兩個方法:

//在當(dāng)前時間往后delay個毫秒開始執(zhí)行
public void schedule(TimerTask task, long delay) {...}
//在指定的time時間點(diǎn)執(zhí)行
public void schedule(TimerTask task, Date time) {...}

第二種Fixed Delay模式也提供了以下兩個方法

//從當(dāng)前時間開始delay個毫秒數(shù)開始定期執(zhí)行,周期是period個毫秒數(shù)
public void schedule(TimerTask task, long delay, long period) {...}
////從指定的firstTime開始定期執(zhí)行,往后每次執(zhí)行的周期是period個毫秒數(shù)
public void schedule(TimerTask task, Date firstTime, long period){...}

它的工作方式是:

第一次執(zhí)行的時間將按照指定的時間點(diǎn)執(zhí)行(如果此時TimerThread不在執(zhí)行其他任務(wù)),如有其他任務(wù)在執(zhí)行,那就需要等到其他任務(wù)執(zhí)行完成才能執(zhí)行。

從第二次開始,每次任務(wù)的執(zhí)行時間是上一次任務(wù)開始執(zhí)行的時間加上指定的period毫秒數(shù)。

如何理解呢,我們還是看代碼

public static void main(String[] args) {
        TimerTask task1 = new DemoTimerTask("Task1");
        TimerTask task2 = new DemoTimerTask("Task2");
        Timer timer = new Timer();
        timer.schedule(task1, 1000, 5000);
        timer.schedule(task2, 1000, 5000);
}
    
static class DemoTimerTask extends TimerTask {
        private String taskName;
        private DateFormat df = new SimpleDateFormat("HH:mm:ss---");
        
        public DemoTimerTask(String taskName) {
            this.taskName = taskName;
        }
        
        @Override
        public void run() {
            System.out.println(df.format(new Date()) + taskName + " is working.");
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(df.format(new Date()) + taskName + " finished work.");
        }
}

task1和task2是幾乎同時執(zhí)行的兩個任務(wù),而且執(zhí)行時長都是2秒鐘,如果此時我們把第六行注掉不執(zhí)行,我們將得到如下結(jié)果(和第三種Fixed Rate模式結(jié)果相同):

13:42:58---Task1 is working.
13:43:00---Task1 finished work.
13:43:03---Task1 is working.
13:43:05---Task1 finished work.
13:43:08---Task1 is working.
13:43:10---Task1 finished work.

如果打開第六行,我們再看下兩個任務(wù)的執(zhí)行情況。我們是期望兩個任務(wù)能夠同時執(zhí)行,但是Task2是在Task1執(zhí)行完成后才開始執(zhí)行(原因是TimerThread是單線程的,每個定時任務(wù)的執(zhí)行也在該線程內(nèi)完成,當(dāng)多個任務(wù)同時需要執(zhí)行時,只能是阻塞了),從而導(dǎo)致Task2第二次執(zhí)行的時間是它上一次執(zhí)行的時間(13:43:57)加上5秒鐘(13:44:02)。

13:43:55---Task1 is working.
13:43:57---Task1 finished work.
13:43:57---Task2 is working.
13:43:59---Task2 finished work.
13:44:00---Task1 is working.
13:44:02---Task1 finished work.
13:44:02---Task2 is working.
13:44:04---Task2 finished work.

那如果此時還有個Task3也是同樣的時間點(diǎn)和間隔執(zhí)行會怎么樣呢?

結(jié)論是:也將依次排隊,執(zhí)行的時間依賴兩個因素:

1.上次執(zhí)行的時間

2.期望執(zhí)行的時間點(diǎn)上有沒有其他任務(wù)在執(zhí)行,有則只能排隊了

我們接下來看下第三種Fixed Rate模式,我們將上面的代碼稍作修改:

public static void main(String[] args) {
        TimerTask task1 = new DemoTimerTask("Task1");
        TimerTask task2 = new DemoTimerTask("Task2");
        
        Timer timer = new Timer();
        timer.scheduleAtFixedRate(task1, 1000, 5000);
        timer.scheduleAtFixedRate(task2, 1000, 5000);
}
    
static class DemoTimerTask extends TimerTask {
        private String taskName;
        private DateFormat df = new SimpleDateFormat("HH:mm:ss---");
        
        public DemoTimerTask(String taskName) {
            this.taskName = taskName;
        }
        
        @Override
        public void run() {
            System.out.println(df.format(new Date()) + taskName + " is working.");
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(df.format(new Date()) + taskName + " finished work.");
        }
}

Task1和Task2還是在相同的時間點(diǎn),按照相同的周期定時執(zhí)行任務(wù),我們期望Task1能夠每5秒定時執(zhí)行任務(wù),期望的時間點(diǎn)是:14:21:47-14:21:52-14:21:57-14:22:02-14:22:07,實際上它能夠交替著定期執(zhí)行,原因是Task2也會定期執(zhí)行,并且對TaskQueue的鎖他們是交替著拿的(這個在下面分析TimerThread源碼的時候會講到)

14:21:47---Task1 is working.
14:21:49---Task1 finished work.
14:21:49---Task2 is working.
14:21:51---Task2 finished work.
14:21:52---Task2 is working.
14:21:54---Task2 finished work.
14:21:54---Task1 is working.
14:21:56---Task1 finished work.
14:21:57---Task1 is working.
14:21:59---Task1 finished work.
14:21:59---Task2 is working.
14:22:01---Task2 finished work.

TimerThread

上面我們主要講了Timer的一些主要源碼及定時模式,下面我們來分析下支撐Timer的定時任務(wù)線程TimerThread。

TimerThread大概流程圖如下:

TimerThread流程

源碼解釋如下:

private void mainLoop() {
        while (true) {
            try {
                TimerTask task;
                boolean taskFired;
                synchronized(queue) {
                    // 如果queue里面沒有要執(zhí)行的任務(wù),則掛起TimerThread線程
                    while (queue.isEmpty() && newTasksMayBeScheduled)
                        queue.wait();
                    // 如果TimerThread被激活,queue里面還是沒有任務(wù),則介紹該線程的無限循環(huán),不再接受新任務(wù)
                    if (queue.isEmpty())
                        break; 

                    long currentTime, executionTime;
                    // 獲取queue隊列里面下一個要執(zhí)行的任務(wù)(根據(jù)時間排序,也就是接下來最近要執(zhí)行的任務(wù))
                    task = queue.getMin();
                    synchronized(task.lock) {
                        if (task.state == TimerTask.CANCELLED) {
                            queue.removeMin();
                            continue;  // No action required, poll queue again
                        }
                        currentTime = System.currentTimeMillis();
                        executionTime = task.nextExecutionTime;
                        // taskFired表示是否需要立刻執(zhí)行線程,當(dāng)task的下次執(zhí)行時間到達(dá)當(dāng)前時間點(diǎn)時為true
                        if (taskFired = (executionTime<=currentTime)) {
                            //task.period==0表示這個任務(wù)只需要執(zhí)行一次,這里就從queue里面刪掉了
                            if (task.period == 0) { 
                                queue.removeMin();
                                task.state = TimerTask.EXECUTED;
                            } else { // Repeating task, reschedule
                                //針對task.period不等于0的任務(wù),則計算它的下次執(zhí)行時間點(diǎn)
                                //task.period<0表示是fixed delay模式的任務(wù)
                                //task.period>0表示是fixed rate模式的任務(wù)
                                queue.rescheduleMin(
                                  task.period<0 ? currentTime   - task.period
                                                : executionTime + task.period);
                            }
                        }
                    }
                    // 如果任務(wù)的下次執(zhí)行時間還沒有到達(dá),則掛起TimerThread線程executionTime - currentTime毫秒數(shù),到達(dá)執(zhí)行時間點(diǎn)再自動激活
                    if (!taskFired) 
                        queue.wait(executionTime - currentTime);
                }
                // 如果任務(wù)的下次執(zhí)行時間到了,則執(zhí)行任務(wù)
                // 注意:這里任務(wù)執(zhí)行沒有另起線程,還是在TimerThread線程執(zhí)行的,所以當(dāng)有任務(wù)在同時執(zhí)行時會出現(xiàn)阻塞
                if (taskFired)  
                    // 這里沒有try catch異常,當(dāng)TimerTask拋出異常會導(dǎo)致整個TimerThread跳出循環(huán),從而導(dǎo)致Timer失效
                    task.run();
            } catch(InterruptedException e) {
            }
        }
}

結(jié)論

通過上面的分析,我們可以得出以下結(jié)論:

  • Timer支持三種模式的定時任務(wù)(一次性任務(wù),F(xiàn)ixed Delay模式,F(xiàn)ixed Rate模式)
  • Timer中的TimerThread是單線程模式,因此導(dǎo)致所有定時任務(wù)不能同時執(zhí)行,可能會出現(xiàn)延遲
  • TimerThread中并沒有處理好任務(wù)的異常,因此每個TimerTask的實現(xiàn)必須自己try catch防止異常拋出,導(dǎo)致Timer整體失效

Demo代碼位置

TimerFixedRateDemo.java

TimerFixedDelayDemo.java

到此這篇關(guān)于深入了解Java定時器中的Timer的原理的文章就介紹到這了,更多相關(guān)Java Timer原理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 使用JDBC工具類實現(xiàn)簡單的登錄管理系統(tǒng)

    使用JDBC工具類實現(xiàn)簡單的登錄管理系統(tǒng)

    這篇文章主要為大家詳細(xì)介紹了使用JDBC工具類實現(xiàn)簡單的登錄管理系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-02-02
  • springboot+vue制作后臺管理系統(tǒng)項目

    springboot+vue制作后臺管理系統(tǒng)項目

    本文詳細(xì)介紹了后臺管理使用springboot+vue制作,以分步驟、圖文的形式詳細(xì)講解,大家有需要的可以參考參考
    2021-08-08
  • Spring?Boot?2.6.x整合Swagger啟動失敗報錯問題的完美解決辦法

    Spring?Boot?2.6.x整合Swagger啟動失敗報錯問題的完美解決辦法

    這篇文章主要給大家介紹了關(guān)于Spring?Boot?2.6.x整合Swagger啟動失敗報錯問題的完美解決辦法,文中通過實例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2022-03-03
  • java使用HttpSession實現(xiàn)QQ訪問記錄

    java使用HttpSession實現(xiàn)QQ訪問記錄

    這篇文章主要介紹了java使用HttpSession實現(xiàn)QQ的訪問記錄的相關(guān)資料,需要的朋友可以參考下
    2016-03-03
  • Java創(chuàng)建對象(顯式創(chuàng)建和隱含創(chuàng)建)

    Java創(chuàng)建對象(顯式創(chuàng)建和隱含創(chuàng)建)

    本文詳細(xì)介紹對象的創(chuàng)建,在 Java 語言中創(chuàng)建對象分顯式創(chuàng)建與隱含創(chuàng)建兩種情況,顯式創(chuàng)建和隱含創(chuàng)建,,需要的朋友可以參考下面文章的具體內(nèi)容
    2021-09-09
  • Java中toString函數(shù)的使用示例代碼

    Java中toString函數(shù)的使用示例代碼

    toString()函數(shù)用于將當(dāng)前對象以字符串的形式返回,比如我定義了一個User類,創(chuàng)建了一個user對象,然后使用相應(yīng)命令去打印user對象,本文結(jié)合示例代碼介紹了toString函數(shù)的使用,需要的朋友可以參考下
    2024-02-02
  • JAVA中excel導(dǎo)出一對多合并具體實現(xiàn)

    JAVA中excel導(dǎo)出一對多合并具體實現(xiàn)

    項目中經(jīng)常會使用到導(dǎo)出功能,有導(dǎo)出Word,有導(dǎo)出Excel的,下面這篇文章主要給大家介紹了關(guān)于JAVA中excel導(dǎo)出一對多合并具體實現(xiàn)的相關(guān)資料,需要的朋友可以參考下
    2023-09-09
  • 如何在 Java 中實現(xiàn)一個 redis 緩存服務(wù)

    如何在 Java 中實現(xiàn)一個 redis 緩存服務(wù)

    為什么要使用緩存?說到底是為了提高系統(tǒng)的運(yùn)行速度。將用戶頻繁訪問的內(nèi)容存放在離用戶最近,訪問速度最快的地方,提高用戶的響應(yīng)速度。下面我們來一起深入學(xué)習(xí)一下吧
    2019-06-06
  • java生成圖片驗證碼返回base64圖片信息方式

    java生成圖片驗證碼返回base64圖片信息方式

    這篇文章主要介紹了java生成圖片驗證碼返回base64圖片信息方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-08-08
  • 解決springboot中@DynamicUpdate注解無效的問題

    解決springboot中@DynamicUpdate注解無效的問題

    這篇文章主要介紹了解決springboot中@DynamicUpdate注解無效的問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-07-07

最新評論