在需要定時并且周期執(zhí)行任務(wù)時，在最初的JAVA工具類庫中，Timer可以實現(xiàn)任務(wù)的定時周期執(zhí)行的需求，不過有一定的缺陷，比如，Timer是基于絕對時間而非相對時間，因此Timer對系統(tǒng)時鐘比較敏感，本文就是討論的Timer定時周期執(zhí)行任務(wù)的問題。

代碼清單1：TimerPrinter.java

package org.4spaces;

import java.util.Date;

import java.util.Random;

import java.util.TimerTask;

public class TimerPrinter extends TimerTask {

@Override

public void run() {

String base = "timerprinterbeginprinting.....";

Random random = new Random();

StringBuffer sb = new StringBuffer();

int number = 0;

for (int i = 0; i < 10; i++) {

number = random.nextInt(base.length());

sb.append(base.charAt(number));

}

System.out.println(new Date() + "," + sb.toString());

}

}

以上代碼的功能是：輸出代碼執(zhí)行時間和長度為10的字符串，這里我們將輸出時間打印出來，近似認(rèn)為是任務(wù)執(zhí)行的時間。。

代碼清單2：TimerLongTask.java

import java.util.TimerTask;

import java.util.concurrent.TimeUnit;

public class TimerLongTask extends TimerTask {

@Override

public void run() {

System.out.println("TimerLongTask:開始沉睡");

try {

TimeUnit.SECONDS.sleep(10);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println("TimerLongTask:已經(jīng)醒來");

}

}

以上代碼的功能：啟動了一個長任務(wù)，讓任務(wù)沉睡10s。

代碼清單3：TimerTest.java

package org.4spaces;

import java.util.Timer;

import java.util.concurrent.TimeUnit;

public class TimerTest {

public static void main(String[] args) throws InterruptedException {

Timer timer = new Timer();

timer.schedule(new TimerPrinter(), 1);

timer.schedule(new TimerLongTask(), 1);

timer.schedule(new TimerPrinter(), 2);

TimeUnit.SECONDS.sleep(20);

timer.cancel();

}

}

以上代碼的功能：定時執(zhí)行任務(wù)，我們先提交了一個打印任務(wù)，且讓它延遲1毫秒執(zhí)行，緊接著我們又提交了一個TimerLongTask長任務(wù)，且讓它也延遲1毫秒執(zhí)行，最后我們再提交一個打印任務(wù)，延遲2毫秒執(zhí)行。然后讓主線程沉睡20秒后關(guān)閉timer。執(zhí)行結(jié)果如下：

Sat Nov 01 18:05:49 CST 2014,rigtr.meit

TimerLongTask:開始沉睡

TimerLongTask:已經(jīng)醒來

Sat Nov 01 18:05:59 CST 2014,rgnneg.nni

從執(zhí)行結(jié)果來看：第一次打印任務(wù)我們讓延遲一秒后執(zhí)行，沉睡任務(wù)我們也是設(shè)置的延遲一秒執(zhí)行，第二次打印任務(wù)我們設(shè)置的是延遲2秒執(zhí)行，執(zhí)行結(jié)果第一次打印和第二次打印間隔為10秒，這個間隔正好是沉睡任務(wù)的時間，通過分析我們得出： Timer用來執(zhí)行任務(wù)的線程只有一個，所以任務(wù)時逐一執(zhí)行的。接下來我們查看一下源碼驗證一下，如下：

private TaskQueue queue = new TaskQueue();

private TimerThread thread = new TimerThread(queue);

這兩行代碼來自Timer源碼，我們可以看到在第一次創(chuàng)建了Timer時就已經(jīng)創(chuàng)建了一個thread和一個queue，因此只有一個線程來執(zhí)行我們的任務(wù)。

那么Timer是如何來執(zhí)行任務(wù)的？

首先我們調(diào)用timer.schedule方法，將任務(wù)提交到timer中，Timer中有很多重載的schedule方法，但它們都會調(diào)用同一個方法即sched方法。這個方法會將我們提交的任務(wù)添加到TaskQueue的隊列中(即queue)，在每次添加時都會根據(jù)nextExecutionTime大小來調(diào)整隊列中任務(wù)的順序，讓nextExecutionTime最小的排在隊列的最前端，nextExecutionTime最大的排在隊列的最后端。在創(chuàng)建Timer時，我們同時也創(chuàng)建了一個TimerThread即thread，并且啟動了這個線程:

public Timer(String name) {

thread.setName(name);

thread.start();

}

那么逐一執(zhí)行的次序又是怎么樣的呢？

我們來調(diào)整一下代碼：

代碼清單4：TimerTest.java

package org.4spaces;

import java.util.Timer;

import java.util.concurrent.TimeUnit;

public class TimerTest {

public static void main(String[] args) throws InterruptedException {

Timer timer = new Timer();

timer.schedule(new TimerPrinter(), 1);

timer.schedule(new TimerPrinter(), 2);

timer.schedule(new TimerLongTask(), 1);

TimeUnit.SECONDS.sleep(20);

timer.cancel();

}

}

執(zhí)行結(jié)果：

Sat Nov 01 18:19:34 CST 2014,e.pmn.nimn

TimerLongTask:開始沉睡

TimerLongTask:已經(jīng)醒來

Sat Nov 01 18:19:44 CST 2014,bnrrn..tgp

我們看到，打印任務(wù)2在沉睡任務(wù)執(zhí)行之后再執(zhí)行。

實際上，timer.schedule()這個方法，會將我們添加的任務(wù)，按照等待執(zhí)行的時間長短排成隊列，等待時間短的排在前面。

重復(fù)執(zhí)行任務(wù)由方法：timer.scheduleAtFixedRate()來完成，比如：

Timer timer = new Timer();

timer.scheduleAtFixedRate(new TimerPrinter(), 3000, 5000);

表示，第一次執(zhí)行時等待3s，然后每個5s執(zhí)行一次該任務(wù)。

由于Timer只使用一個線程運行所有的任務(wù)，那么當(dāng)一個任務(wù)拋出運行時異常后會有什么樣的情形呢？其他的任務(wù)是否可以繼續(xù)？我們已經(jīng)有了前面的知識可以先猜想一個結(jié)果：因為Timer只使用一個線程運行所有的任務(wù)，所以當(dāng)一個線程拋出運行時異常時，這個線程就基本掛了，不會在執(zhí)行后續(xù)的任何代碼，因此我們可以斷言，當(dāng)一個任務(wù)拋出運行時異常時，后續(xù)任務(wù)都不可以執(zhí)行。為了證明這個猜想，我們需要一個可以拋出異常的任務(wù)，如下：

public class TimerExceptionTask extends TimerTask {

@Override

public void run() {

System.out.println("TimerExceptionTask: "+new Date());

throw new RuntimeException();

}

}

這個任務(wù)拋出一個運行時異常。接著我們需要定義一下我們?nèi)蝿?wù)執(zhí)行的順序：先執(zhí)行一個正常的任務(wù)，然后在執(zhí)行一個拋出異常的任務(wù)，最后在執(zhí)行一個正常的任務(wù)，如下：

Timer timer = new Timer();

timer.schedule(new TimerTask1(), 1000);

timer.schedule(new TimerExceptionTask(), 3000);

timer.schedule(new TimerTask1(), 5000);

TimeUnit.SECONDS.sleep(6);

timer.cancel();

延遲1秒執(zhí)行正常輸出字符串的任務(wù)，延遲3秒執(zhí)行拋出異常的任務(wù)，延遲5秒執(zhí)行正常輸出字符串的任務(wù)，看一下結(jié)果：

Thu Apr 21 13:40:23 CST 2011,lk7fjneyyu

TimerExceptionTask: Thu Apr 21 13:40:25 CST 2011

Exception in thread "Timer-0" java.lang.RuntimeException

at org.victorzhzh.concurrency.TimerExceptionTask.run(TimerExceptionTask.java:11)

at java.util.TimerThread.mainLoop(Timer.java:512)

at java.util.TimerThread.run(Timer.java:462)

并沒有輸出兩個字符串，只執(zhí)行了第一次的輸出字符串任務(wù)，說明當(dāng)拋出運行時異常時，其后續(xù)任務(wù)不可能被執(zhí)行。鑒于Timer的缺陷，所以對它的使用還是要謹(jǐn)慎的，還好并發(fā)包中為我們提供了相應(yīng)的替代品：ScheduledThreadPoolExecutor。

Java中Timer和ThreadPoolExecutor學(xué)習(xí)比較系列文章：

總結(jié)

以上是生活随笔為你收集整理的java捕获定时器抛出的异常_详细了解Java中定时器Timer的使用及缺陷分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。