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

问题描述:

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

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

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

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

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

问题定位:

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

解决方案:

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

//等待线程池所有线程执行完毕,再执行下一个定时任务
//shutdown()方法会标记之后,等待所有线程执行完毕后,修改其线程池状态,isTerminated()方法为shutdown真正之后才会返回true
executorService.shutdown(); while (true) { if (executorService.isTerminated()) { logger.info("SendLimitTemplateTimer end"); break; } }
原文地址:https://www.cnblogs.com/zengweiming/p/7514255.html