Java實現(xiàn)并發(fā)執(zhí)行定時任務并手動控制開始結束

更新時間：2024年05月13日 09:51:57 作者：日常500

這篇文章主要介紹了Java實現(xiàn)并發(fā)執(zhí)行定時任務并手動控制開始結束,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

簡介

最近有一點富裕的時間，就想分享一下關于并發(fā)定時任務的內容，我也是查閱相關博客文檔并自己搗鼓出來的一點小思路，歡迎各路大佬批評指正…

應用場景

不知道大家對定時任務的使用情況是怎樣，就我個人而言接觸的也比較少一點，分享一下我的使用案例，簡單點一下使用場景。

最近需要獲取硬件相關的信息（傳感器信息）到平臺上進行一個展示，相信有一點經(jīng)驗的小伙伴應該了解與硬件交互需要涉及到心跳計時等等（就不細說了），所以就用到定時任務

我使用的是ThreadPoolTaskScheduler類來進行定時任務的控制的

下面是我寫的小Demo

代碼邏輯

代碼片（可直接運行）

package com.pj.apps.socket.tower;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ScheduledFuture;

import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;


public class TaskTest {
	//需要對它進行初始化
	private static ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); 
	//存儲定時任務編號及任務
	private static Map<String,ScheduledFuture<?>> map = new HashMap<>();
	//使用靜態(tài)代碼塊來初始化ThreadPoolTaskScheduler
	static {
		threadPoolTaskScheduler.initialize();
	}
	//開啟定時任務的方法
    private static void startCron(String tNo) {
		//通過使用它的方法來對任務進行開啟和關閉，使用Cron表達式，表示時間間隔并重復執(zhí)行
    	ScheduledFuture<?> future = threadPoolTaskScheduler.schedule(new MyRunnable(tNo), new CronTrigger("*/5 * * * * ?"));
        map.put(tNo, future);
    } 
 
    //停關閉定時任務
    private static void closeCron(ScheduledFuture<?> future) {
       if (future != null) {
           future.cancel(true);
       }
    }

    //定時任務線程
    private static class MyRunnable implements Runnable {
    	private String tNo;
    	public MyRunnable(String tNo) {
    		this.tNo = tNo;
    	}
        @Override
        public void run() {
            System.out.println("線程編號"+tNo+"定時任務邏輯內容...");
        }
    } 
	public static void main(String[] args) {
		startCron("9527");
		startCron("9528");
	}
}