前言
眾所周知在spring 3.0版本后,自帶了一個定時任務(wù)工具,而且使用簡單方便,不用配置文件,可以動態(tài)改變執(zhí)行狀態(tài)。也可以使用cron表達式設(shè)置定時任務(wù)。
被執(zhí)行的類要實現(xiàn)Runnable接口
TaskScheduler接口
TaskScheduler是一個接口,TaskScheduler接口下定義了6個方法
- schedule(Runnable task, Trigger trigger);
指定一個觸發(fā)器執(zhí)行定時任務(wù)。可以使用CronTrigger來指定Cron表達式,執(zhí)行定時任務(wù)
- CronTrigger t = new CronTrigger("0 0 10,14,16 * * ?");
- taskScheduler.schedule(this, t);
- schedule(Runnable task, Date startTime);
指定一個具體時間點執(zhí)行定時任務(wù),可以動態(tài)的指定時間,開啟任務(wù)。只執(zhí)行一次。(比Timer好用多了。早發(fā)現(xiàn)這接口就好了。。。)
- scheduleAtFixedRate(Runnable task, long period);
立即執(zhí)行,循環(huán)任務(wù),指定一個執(zhí)行周期(毫秒計時)
PS:不管上一個周期是否執(zhí)行完,到時間下個周期就開始執(zhí)行
- scheduleAtFixedRate(Runnable task, Date startTime, long period);
指定時間開始執(zhí)行,循環(huán)任務(wù),指定一個間隔周期(毫秒計時)
PS:不管上一個周期是否執(zhí)行完,到時間下個周期就開始執(zhí)行
- scheduleWithFixedDelay(Runnable task, long delay);
立即執(zhí)行,循環(huán)任務(wù),指定一個間隔周期(毫秒計時)
PS:上一個周期執(zhí)行完,等待delay時間,下個周期開始執(zhí)行
- scheduleWithFixedDelay(Runnable task, Date startTime, long delay);
指定時間開始執(zhí)行,循環(huán)任務(wù),指定一個間隔周期(毫秒計時)
PS:上一個周期執(zhí)行完,等待delay時間,下個周期開始執(zhí)行
TaskScheduler下有五個實現(xiàn)類
1、ConcurrentTaskScheduler
以當前線程執(zhí)行任務(wù)。如果任務(wù)簡單,可以直接使用這個類來執(zhí)行。快捷方便。
PS:這是單線程運行
- public class LocTest implements Runnable {
- private ConcurrentTaskScheduler tpts = new ConcurrentTaskScheduler();
- private void start() {
- tpts.schedule(this, new Date());
- }
- public void run() {
- Thread ct = Thread.currentThread();
- System.out.println("current id:"+ct.getId());
- System.out.println("current name:"+ct.getName());
- }
- public static void main(String[] args) {
- new LocTest().start();
- }
- }
2、DefaultManagedTaskScheduler
以當前線程執(zhí)行任務(wù),這是ConcurrentTaskScheduler的子類,添加了JNDI的支持。和ConcurrentTaskScheduler一樣的用法,需要使用JNDI可以單獨設(shè)置
3、ThreadPoolTaskScheduler
TaskScheduler接口的默認實現(xiàn)類,多線程定時任務(wù)執(zhí)行。可以設(shè)置執(zhí)行線程池數(shù)(默認一個線程)。
PS:
-
使用前必須得先調(diào)用
initialize()
【初始化方法】 -
有
shutDown()
方法,執(zhí)行完后可以關(guān)閉線程
- public class LocTest implements Runnable {
- private ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
- private void start() {
- taskScheduler.setPoolSize(10);
- //必須得先初始化,才能使用
- taskScheduler.initialize();
- taskScheduler.schedule(this, new Date());
- }
- public void run() {
- Thread ct = Thread.currentThread();
- System.out.println("current id:"+ct.getId());
- System.out.println("current name:"+ct.getName());
- }
- public static void main(String[] args) {
- new LocTest().start();
- }
- }
4、TimerManagerTaskScheduler
這個沒有使用到,就沒具體了解,有時間再補充。有了解的歡迎來補充。
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學習或者工作能帶來一定的幫助,如果有疑問大家可以留言交流。