线程池ExecutorService与quartz搭配出现的问题

Posted 2020-10-06 博客已迁移至：https://tidyko.com

问题描述：

使用quartz定时推送微信公众号模板消息，一分钟推送一次，定时器里面使用了一个ExecutorService线程池，大小为5个。

批量获取数据之后，全部数据都被分配到n/5的线程池里面等待执行，分配完成之后，系统就默认了这次任务已经执行完毕。

下个一分钟到了的时候，继续获取指定状态的数据，重复上面的入线程池操作。

导致，在之前的任务里面已经分配到线程池中，但是还没有来得及处理的数据，在下一个定时任务开始时重新被放进去了线程池里面。

如此累计，导致最后有的用户多次重复收到了同一条模板消息。

问题定位：

定时任务没有等待ExecutorService所有任务执行完毕之后再结束此次任务，导致的重复累积推送问题。

解决方案：

在定时器方法尾部添加判断线程池状态代码，阻塞任务结束执行。

//等待线程池所有线程执行完毕，再执行下一个定时任务
//shutdown()方法会标记之后，等待所有线程执行完毕后，修改其线程池状态，isTerminated()方法为shutdown真正之后才会返回true

executorService.shutdown();  
while (true) {  
    if (executorService.isTerminated()) {  
        logger.info("SendLimitTemplateTimer end"); 
        break;  
    }  
}