最近在項目中遇到了一個問題, 對于新建的活動, 活動設(shè)置了開始時間和結(jié)束時間, 也就是數(shù)據(jù)庫中的一個狀態(tài)碼的改變而已. 但是,這里就有問題了, 如何去實現(xiàn)到時間更改活動狀態(tài)呢?

1. 剛開始的時候,我想了下定時任務(wù), 但是怎么也想不出配置的時間問題,? 對于活動來說, 配置的定時任務(wù)肯定是有延遲的, 這就導(dǎo)致了時間到了,但是活動還未開始或者結(jié)束.?
2. 后來在萬般苦思之后,相處了一個笨方法,就是在外部調(diào)用的每個接口前面加上了一個方法來處理活動的開始和結(jié)束,這樣的話接口查詢到的就是正常的開始或者結(jié)束的數(shù)據(jù),但是頁面上顯示的活動還是有延時.本來已近結(jié)束,但是頁面顯示進行中.這樣也會出現(xiàn)問題,即可能會被投訴虛假活動.

3.終于在被主管罵了一頓之后,才得知,在juc包中還有定時器這么個方法, 即創(chuàng)建一個定時的線程,利用ScheduledExecutorService 去定時執(zhí)行,這樣就會在指定時間更改活動狀態(tài),這樣任務(wù)就算圓滿完成,下面附上部分代碼,以作備忘

?

?

//執(zhí)行定時對象池private ScheduledExecutorService scheduleExecutor = Executors.newScheduledThreadPool(2);//所有的定時任務(wù)@SuppressWarnings("rawtypes")private Map<String, List<Future>> currentJob = new HashMap<>();/*** 添加啟動定時任務(wù)* @param id* @param millSecond* @param clearFlag* @return*/@SuppressWarnings("rawtypes")public synchronized Future addStartJob(String id, Long millSecond, boolean clearFlag) {if (clearFlag) {//清除任務(wù) clearJobsById(id);}if (null == currentJob.get(id)) {currentJob.put(id, new ArrayList<>());}ScheduledFuture<?> scheduledFuture = scheduleExecutor.schedule(new Runnable() {@Overridepublic void run() {logger.debug("/r/n 活動定時生效 活動ID: " + id + "時間: " + millSecond);try {startTask(id);} catch (Exception e) {e.printStackTrace();logger.error(e.getMessage(), e.fillInStackTrace());}}}, millSecond, TimeUnit.MILLISECONDS);//加入集合 currentJob.get(id).add(scheduledFuture);return null;}

/**
* 通過id清除任務(wù)
* @param id
*/
public void clearJobsById(String id) {
if (null != currentJob.get(id)) {
for (@SuppressWarnings("rawtypes") Future future : currentJob.get(id)) {
if (null != future && !future.isDone()) {
future.cancel(false); //正在運行是否干擾
}
}
currentJob.remove(id);
}
logger.debug("/r/n 活動清除定時任務(wù)! 任務(wù)ID: " + id);
currentJob.put(id, new ArrayList<>());
}

} ?

?

轉(zhuǎn)載于:https://www.cnblogs.com/xQlover/p/11606762.html

總結(jié)

以上是生活随笔為你收集整理的SpringBoot实现定时器定时处理任务的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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