快捷導(dǎo)航

java高并發(fā)ScheduledThreadPoolExecutor與Timer區(qū)別

更新時(shí)間：2022年10月12日 16:05:13 作者：冰河

這篇文章主要為大家介紹了java高并發(fā)ScheduledThreadPoolExecutor與Timer區(qū)別，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

正文

JDK 1.5開始提供ScheduledThreadPoolExecutor類，ScheduledThreadPoolExecutor類繼承ThreadPoolExecutor類重用線程池實(shí)現(xiàn)了任務(wù)的周期性調(diào)度功能。在JDK 1.5之前，實(shí)現(xiàn)任務(wù)的周期性調(diào)度主要使用的是Timer類和TimerTask類。本文，就簡(jiǎn)單介紹下ScheduledThreadPoolExecutor類與Timer類的區(qū)別，ScheduledThreadPoolExecutor類相比于Timer類來(lái)說(shuō)，究竟有哪些優(yōu)勢(shì)，以及二者分別實(shí)現(xiàn)任務(wù)調(diào)度的簡(jiǎn)單示例。

二者的區(qū)別

線程角度

Timer是單線程模式，如果某個(gè)TimerTask任務(wù)的執(zhí)行時(shí)間比較久，會(huì)影響到其他任務(wù)的調(diào)度執(zhí)行。
ScheduledThreadPoolExecutor是多線程模式，并且重用線程池，某個(gè)ScheduledFutureTask任務(wù)執(zhí)行的時(shí)間比較久，不會(huì)影響到其他任務(wù)的調(diào)度執(zhí)行。

系統(tǒng)時(shí)間敏感度

Timer調(diào)度是基于操作系統(tǒng)的絕對(duì)時(shí)間的，對(duì)操作系統(tǒng)的時(shí)間敏感，一旦操作系統(tǒng)的時(shí)間改變，則Timer的調(diào)度不再精確。
ScheduledThreadPoolExecutor調(diào)度是基于相對(duì)時(shí)間的，不受操作系統(tǒng)時(shí)間改變的影響。

是否捕獲異常

Timer不會(huì)捕獲TimerTask拋出的異常，加上Timer又是單線程的。一旦某個(gè)調(diào)度任務(wù)出現(xiàn)異常，則整個(gè)線程就會(huì)終止，其他需要調(diào)度的任務(wù)也不再執(zhí)行。
ScheduledThreadPoolExecutor基于線程池來(lái)實(shí)現(xiàn)調(diào)度功能，某個(gè)任務(wù)拋出異常后，其他任務(wù)仍能正常執(zhí)行。

任務(wù)是否具備優(yōu)先級(jí)

Timer中執(zhí)行的TimerTask任務(wù)整體上沒有優(yōu)先級(jí)的概念，只是按照系統(tǒng)的絕對(duì)時(shí)間來(lái)執(zhí)行任務(wù)。
ScheduledThreadPoolExecutor中執(zhí)行的ScheduledFutureTask類實(shí)現(xiàn)了java.lang.Comparable接口和java.util.concurrent.Delayed接口，這也就說(shuō)明了ScheduledFutureTask類中實(shí)現(xiàn)了兩個(gè)非常重要的方法，一個(gè)是java.lang.Comparable接口的compareTo方法，一個(gè)是java.util.concurrent.Delayed接口的getDelay方法。在ScheduledFutureTask類中compareTo方法方法實(shí)現(xiàn)了任務(wù)的比較，距離下次執(zhí)行的時(shí)間間隔短的任務(wù)會(huì)排在前面，也就是說(shuō)，距離下次執(zhí)行的時(shí)間間隔短的任務(wù)的優(yōu)先級(jí)比較高。而getDelay方法則能夠返回距離下次任務(wù)執(zhí)行的時(shí)間間隔。

是否支持對(duì)任務(wù)排序

Timer不支持對(duì)任務(wù)的排序。
ScheduledThreadPoolExecutor類中定義了一個(gè)靜態(tài)內(nèi)部類DelayedWorkQueue，DelayedWorkQueue類本質(zhì)上是一個(gè)有序隊(duì)列，為需要調(diào)度的每個(gè)任務(wù)按照距離下次執(zhí)行時(shí)間間隔的大小來(lái)排序

能否獲取返回的結(jié)果

Timer中執(zhí)行的TimerTask類只是實(shí)現(xiàn)了java.lang.Runnable接口，無(wú)法從TimerTask中獲取返回的結(jié)果。
ScheduledThreadPoolExecutor中執(zhí)行的ScheduledFutureTask類繼承了FutureTask類，能夠通過(guò)Future來(lái)獲取返回的結(jié)果。

通過(guò)以上對(duì)ScheduledThreadPoolExecutor類和Timer類的分析對(duì)比，相信在JDK 1.5之后，就沒有使用Timer來(lái)實(shí)現(xiàn)定時(shí)任務(wù)調(diào)度的必要了。

二者簡(jiǎn)單的示例

這里，給出使用Timer和ScheduledThreadPoolExecutor實(shí)現(xiàn)定時(shí)調(diào)度的簡(jiǎn)單示例，為了簡(jiǎn)便，我這里就直接使用匿名內(nèi)部類的形式來(lái)提交任務(wù)。

Timer類簡(jiǎn)單示例

源代碼示例如下所示。

package io.binghe.concurrent.lab09;
import java.util.Timer;
import java.util.TimerTask;
/**
 * @author binghe
 * @version 1.0.0
 * @description 測(cè)試Timer
 */
public class TimerTest {
    public static void main(String[] args) throws InterruptedException {
        Timer timer = new Timer();
        timer.scheduleAtFixedRate(new TimerTask() {
            @Override
            public void run() {
                System.out.println("測(cè)試Timer類");
            }
        }, 1000, 1000);
        Thread.sleep(10000);
        timer.cancel();
    }
}

運(yùn)行結(jié)果如下所示。

測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類
測(cè)試Timer類

ScheduledThreadPoolExecutor類簡(jiǎn)單示例

源代碼示例如下所示。

package io.binghe.concurrent.lab09;
import java.util.concurrent.*;
/**
 * @author binghe
 * @version 1.0.0
 * @description 測(cè)試ScheduledThreadPoolExecutor
 */
public class ScheduledThreadPoolExecutorTest {
    public static void main(String[] args) throws  InterruptedException {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(3);
        scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                System.out.println("測(cè)試測(cè)試ScheduledThreadPoolExecutor");
            }
        }, 1, 1, TimeUnit.SECONDS);
        //主線程休眠10秒
        Thread.sleep(10000);
        System.out.println("正在關(guān)閉線程池...");
        // 關(guān)閉線程池
        scheduledExecutorService.shutdown();
        boolean isClosed;
        // 等待線程池終止
        do {
            isClosed = scheduledExecutorService.awaitTermination(1, TimeUnit.DAYS);
            System.out.println("正在等待線程池中的任務(wù)執(zhí)行完成");
        } while(!isClosed);
        System.out.println("所有線程執(zhí)行結(jié)束，線程池關(guān)閉");
    }
}

運(yùn)行結(jié)果如下所示。

測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
測(cè)試測(cè)試ScheduledThreadPoolExecutor
正在關(guān)閉線程池...
測(cè)試測(cè)試ScheduledThreadPoolExecutor
正在等待線程池中的任務(wù)執(zhí)行完成
所有線程執(zhí)行結(jié)束，線程池關(guān)閉

注意：關(guān)于Timer和ScheduledThreadPoolExecutor還有其他的使用方法，這里，我就簡(jiǎn)單列出以上兩個(gè)使用示例，更多的使用方法大家可以自行實(shí)現(xiàn)。

以上就是java高并發(fā)ScheduledThreadPoolExecutor與Timer區(qū)別的詳細(xì)內(nèi)容，更多關(guān)于java高并發(fā)ScheduledThreadPoolExecutor Timer的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: