java - 定時任務(wù)TimerTask沒有被全部成功執(zhí)行
問題描述
我這建立了一個TimerManager的類,目的是讓系統(tǒng)跑起來之后,執(zhí)行相應(yīng)的4個任務(wù)。但是,4個任務(wù)之中只有兩個被成功執(zhí)行了,他們分別是timer和timer3,后面的兩個timer2和timer4并沒有被執(zhí)行到。百思不得其解,所以來sf讓各位幫我看看是什么問題,下面是TimerManager的代碼:
public class TimerManager { @Resource RemoteControlController remoteControlController;@Resource ManagementStationService managementStationService; @Resource ControllerStatusController controllerStatusController; // 時間間隔 private static final long PERIOD_DAY = 24 * 60 * 60 * 1000; public static final long PERIOD_DAY2 = 60 * 60 * 1000; private static final long PERIOD_DAY3 = 60 * 60 * 1000; private static final int START_TIME = 1; private static final int START_TIME2 = 0; private Logger log = Logger.getLogger('ServerInfo'); public void initTimerManager() {Calendar calendar = Calendar.getInstance();Calendar calendar2 = Calendar.getInstance();/*** 定制每日1:00執(zhí)行方法 ***/calendar.set(Calendar.HOUR_OF_DAY, START_TIME);calendar.set(Calendar.MINUTE, 0);calendar.set(Calendar.SECOND, 0);/*** 定制每日0:00執(zhí)行方法 ***/calendar2.set(Calendar.HOUR_OF_DAY, START_TIME2);calendar2.set(Calendar.MINUTE, 0);calendar2.set(Calendar.SECOND, 0);Date date = calendar.getTime(); //第一次執(zhí)行定時任務(wù)的時間 ,date重啟不執(zhí)行Date date2 = calendar.getTime();//date2、3重啟執(zhí)行Date date3 = calendar2.getTime();// 如果第一次執(zhí)行定時任務(wù)的時間 小于 當(dāng)前的時間// 此時要在第一次執(zhí)行定時任務(wù)的時間加一天,以便此任務(wù)在下個時間點執(zhí)行。如果不加一天,任務(wù)會立即執(zhí)行。if (date.before(new Date())) { date = this.addDay(date, 1);}Timer timer = new Timer();Timer timer2 = new Timer();Timer timer3 = new Timer();Timer timer4 = new Timer();UpdateDailyEletricPowerTimerTask task = new UpdateDailyEletricPowerTimerTask();UpdateLampStatusTimerTask task2 = new UpdateLampStatusTimerTask();UpdateCurrentEletricDataTimerTask task3 = new UpdateCurrentEletricDataTimerTask();UpdateCurrentControllerStatusTimerTask task4 = new UpdateCurrentControllerStatusTimerTask();// 安排指定的任務(wù)在指定的時間開始進(jìn)行重復(fù)的固定延遲執(zhí)行。timer.schedule(task, date, PERIOD_DAY);timer3.schedule(task3, date3, PERIOD_DAY2);timer4.schedule(task4, date3, PERIOD_DAY3);//先更新路由狀態(tài)timer2.schedule(task2, date2, PERIOD_DAY);//再更新燈狀態(tài) } // 增加或減少天數(shù) public Date addDay(Date date, int num) {Calendar startDT = Calendar.getInstance();startDT.setTime(date);startDT.add(Calendar.DAY_OF_MONTH, num);return startDT.getTime(); }public class UpdateCurrentEletricDataTimerTask extends TimerTask {@Overridepublic void run() { try {// 在這里寫你要執(zhí)行的內(nèi)容/** * 查詢實時功率等數(shù)據(jù) */log.info('-------------UpdateCurrentEletricDataTimerTask正在執(zhí)行--------------');remoteControlController.currentElectricDataCollecting();log.info('-------------UpdateCurrentEletricDataTimerTask執(zhí)行完畢--------------'); } catch (Exception e) {log.info('-------------UpdateCurrentEletricDataTimerTask解析信息發(fā)生異常--------------'); }} }
public class UpdateCurrentControllerStatusTimerTask extends TimerTask {@Overridepublic void run() { try {// 在這里寫你要執(zhí)行的內(nèi)容/** * 查詢實時功率等數(shù)據(jù) */log.info('-------------UpdateCurrentControllerStatusTimerTask正在執(zhí)行--------------');remoteControlController.readRouterStatus();log.info('-------------UpdateCurrentControllerStatusTimerTask執(zhí)行完畢--------------'); } catch (Exception e) {log.info('-------------UpdateCurrentControllerStatusTimerTask解析信息發(fā)生異常--------------'); }} }public class UpdateDailyEletricPowerTimerTask extends TimerTask {@Overridepublic void run() { try {// 在這里寫你要執(zhí)行的內(nèi)容/** * 查詢前昨兩天日凍結(jié)正向有功總電量 */log.info('-------------UpdateDailyEletricPowerTimerTask正在執(zhí)行--------------');remoteControlController.dailyPositiveElectricPowerCollecting();log.info('-------------UpdateDailyEletricPowerTimerTask執(zhí)行完畢--------------'); } catch (Exception e) {log.info('-------------UpdateDailyEletricPowerTimerTask解析信息發(fā)生異常--------------'); }} }public class UpdateLampStatusTimerTask extends TimerTask {@Overridepublic void run() { try {// 在這里寫你要執(zhí)行的內(nèi)容/** * 更新全部燈具狀態(tài) */log.info('-------------UpdateLampStatusTimerTask正在執(zhí)行--------------');List<ManagementStation> mlist = managementStationService.getManagementStationList();int msize = mlist.size();log.info('**********UpdateLampStatusTimerTask獲取的管理所長度為'+msize);if(msize > 0){ String[] arr = new String[msize]; for(int i = 0; i < msize; i++)arr[i] = String.valueOf(mlist.get(i).getMid()); boolean realTime = false; controllerStatusController.UpdateControllerStatus(arr,realTime);}log.info('-------------UpdateLampStatusTimerTask執(zhí)行完畢-------------'); } catch (Exception e) {log.info('-------------UpdateLampStatusTimerTask解析信息發(fā)生異常--------------'); }} }}
問題解答
回答1:我沒用過 Timer,也不打算對如何調(diào)試這個程序提建議。我建議用 quartz 這樣的成熟框架來做這類事情。如果一定要自己設(shè)計的話,Timer 也不是最好的選擇,標(biāo)準(zhǔn)的思路應(yīng)該是:
創(chuàng)建一個守護(hù)線程,管理每個定時任務(wù)的周期;
當(dāng)一個定時任務(wù)執(zhí)行時間到了,守護(hù)線程另開一個線程執(zhí)行這個任務(wù);
如果一個任務(wù)執(zhí)行時間超過周期,則推遲下次執(zhí)行時間到下一個周期。
相關(guān)文章:
1. 輸入地址報以下截圖錯誤,怎么辦?2. python - 《flask web 開發(fā)》一書,數(shù)據(jù)庫中多對多關(guān)系的實現(xiàn)問題?3. thinkphp3 count()方法必須加上字段?4. python中return 語句與 分支語句連用問題5. 這是什么情況???6. node.js - nodejs中mysql子查詢返回多行結(jié)果怎么處理?7. mysql - 瞬間流量很高的網(wǎng)站,要頻繁的插入數(shù)據(jù)到數(shù)據(jù)庫,應(yīng)該怎么解決這個問題?8. mysql 5個left關(guān)鍵 然后再用搜索條件 幾千條數(shù)據(jù)就會卡,如何解決呢9. 怎么php怎么通過數(shù)組顯示sql查詢結(jié)果呢,查詢結(jié)果有多條,如圖。10. python - angular route 與 django urls 沖突怎么解決?
