SpringBoot實現定時器定時處理任務

　　最近在項目中遇到了一個問題, 對於新建的活動, 活動設置了開始時間和結束時間, 也就是數據庫中的一個狀態碼的改變而已. 但是,這里就有問題了, 如何去實現到時間更改活動狀態呢?

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

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

 

 

//執行定時對象池
    private ScheduledExecutorService scheduleExecutor = Executors.newScheduledThreadPool(2);

    //所有的定時任務
    @SuppressWarnings("rawtypes")
    private Map<String, List<Future>> currentJob = new HashMap<>();

    /**
     * 添加啟動定時任務
     * @param id
     * @param millSecond
     * @param clearFlag
     * @return
     */
    @SuppressWarnings("rawtypes")
    public synchronized Future addStartJob(String id, Long millSecond, boolean clearFlag) {
        if (clearFlag) {
            //清除任務
            clearJobsById(id);
        }
        if (null == currentJob.get(id)) {
            currentJob.put(id, new ArrayList<>());
        }

        ScheduledFuture<?> scheduledFuture = scheduleExecutor.schedule(new Runnable() {
            @Override
            public 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清除任務
 * @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  活動清除定時任務! 任務ID: " + id);
    currentJob.put(id, new ArrayList<>());
}

}