天天看點

定時任務的三種實作方法定時任務的三種實作方法

定時任務的三種實作方法

1,普通thread實作

2,TimerTask實作

3,ScheduledExecutorService實作

一、普通thread

這是最常見的,建立一個thread,然後讓它在while循環裡一直運作着,通過sleep方法來達到定時任務的效果。這樣可以快速簡單的實作,代碼如下

package utils;

import java.util.Date;

public class TaskThread {

private static final long timeInterval = 1000;

public static void main(String[] args) {

Runnable runnable = new Runnable() {

public void run() {

while (true) {

Date date = new Date();

System.out.println("#### Test thread ####"+date);

try {

// 休眠時間後再次執行

Thread.sleep(timeInterval);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

};

Thread thread = new Thread(runnable);

thread.start();

}

}

二、用Timer和TimerTask

上面的實作是非常快速簡便的,但它也缺少一些功能。

用Timer和TimerTask的話與上述方法相比有如下好處:

1.當啟動和去取消任務時可以控制

2.第一次執行任務時可以指定你想要的delay時間

在實作時,Timer類可以排程任務,TimerTask則是通過在run()方法裡實作具體任務。

Timer執行個體可以排程多任務,它是線程安全的。

當Timer的構造器被調用時,它建立了一個線程,這個線程可以用來排程任務。

package utils;

import java.util.Date;

import java.util.Timer;

import java.util.TimerTask;

public class TaskTimer {

public static void main(String[] args) {

TimerTask task = new TimerTask() {

@Override

public void run() {

Date date = new Date();

System.out.println("#### Test TimerTask ####" + date);

}

};

Date date = new Date();

System.out.println("目前時間:" + date);

Timer timer = new Timer();

long delay = 5000; // 延遲5秒執行

long intevalPeriod = 1000; // 間隔1秒

timer.scheduleAtFixedRate(task, delay, intevalPeriod);

}

}

三、ScheduledExecutorService

ScheduledExecutorService是從Java SE 5的java.util.concurrent裡,做為并發工具類被引進的,這是最理想的定時任務實作方式。

相比于上兩個方法,它有以下好處:

1.相比于Timer的單線程,它是通過線程池的方式來執行任務的

2.可以很靈活的去設定第一次執行任務delay時間

3.提供了良好的約定,以便設定執行的時間間隔

下面是實作代碼,我們通過ScheduledExecutorService#scheduleAtFixedRate展示這個例子,通過代碼裡參數的控制,首次執行加了delay時間。

package utils;

import java.util.Date;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

public class TaskScheduledExecutorService {

public static void main(String[] args) {

Runnable runnable = new Runnable() {

public void run() {

Date date = new Date();

System.out.println("#### Test ScheduledExecutorService ####"+ date);

}

};

Date date = new Date();

System.out.println("啟動時間:" + date);

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();

// 參數2=延遲,參數3=間隔時間

service.scheduleAtFixedRate(runnable, 5, 1, TimeUnit.SECONDS);

}

}