最近在项目中遇到了一个问题, 对于新建的活动, 活动设置了开始时间和结束时间, 也就是数据库中的一个状态码的改变而已. 但是,这里就有问题了, 如何去实现到时间更改活动状态呢?
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() {@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清除任务
* @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<>());
}
}
