lsm/weixin-java-tools
1
0
Fork 0
mirror of https://gitee.com/binary/weixin-java-tools.git synced 2025-05-04 20:57:47 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🎨 修改消息去重时线程池关闭问题

Browse Source
This commit is contained in:
Binary Wang 2022-09-02 19:40:02 +08:00 committed by GitHub
commit 3918005b1f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
weixin-java-common/src/main/java/me/chanjar/weixin/common/api/WxMessageInMemoryDuplicateCheckerSingleton.java
View File

@ -12,8 +12,8 @@ import java.util.concurrent.TimeUnit;
* @author jiangby * @author jiangby
* @version 1.0 * @version 1.0
* <p> * <p>
* 消息去重，记录消息ID首次出现时的时间戳， * 消息去重，记录消息ID首次出现时的时间戳，
* 15S后定时任务触发时废除该记录消息ID * 15S后定时任务触发时废除该记录消息ID
* </p> * </p>
* created on 2022/5/26 1:32 * created on 2022/5/26 1:32
*/ */
@ -34,7 +34,7 @@ public class WxMessageInMemoryDuplicateCheckerSingleton implements WxMessageDupl
* 线程池 * 线程池
*/ */
private static final ScheduledThreadPoolExecutor SCHEDULED_THREAD_POOL_EXECUTOR = new ScheduledThreadPoolExecutor(1, private static final ScheduledThreadPoolExecutor SCHEDULED_THREAD_POOL_EXECUTOR = new ScheduledThreadPoolExecutor(1,
new ThreadFactoryBuilder().setNameFormat("wxMessage-memory-pool-%d").build(), new ThreadPoolExecutor.AbortPolicy()); new ThreadFactoryBuilder().setNameFormat("wxMessage-memory-pool-%d").setDaemon(true).build(), new ThreadPoolExecutor.AbortPolicy());
/** /**
* 消息id->消息时间戳的map. * 消息id->消息时间戳的map.
@ -71,7 +71,7 @@ public class WxMessageInMemoryDuplicateCheckerSingleton implements WxMessageDupl
* 内部类实现单例 * 内部类实现单例
*/ */
private static class WxMessageInnerClass { private static class WxMessageInnerClass {
static final WxMessageInMemoryDuplicateCheckerSingleton CHECKER_SINGLETON = new WxMessageInMemoryDuplicateCheckerSingleton(); static final WxMessageInMemoryDuplicateCheckerSingleton CHECKER_SINGLETON = new WxMessageInMemoryDuplicateCheckerSingleton();
} }
/** /**