GeezerVison is showing github.com — :art: 修改消息去重时线程池关闭问题 · binarywang/WxJava@3918005
File tree
Expand file treeCollapse file tree
Open diff view settings
weixin-java-common/src/main/java/me/chanjar/weixin/common/api
Expand file treeCollapse file tree
Open diff view settings
Collapse file
Copy file name to clipboardExpand all lines: weixin-java-common/src/main/java/me/chanjar/weixin/common/api/WxMessageInMemoryDuplicateCheckerSingleton.java +4-4Lines changed: 4 additions & 4 deletions | Original file line number | Diff line number | Diff line change |
|---|
|
12 | 12 | * @author jiangby |
13 | 13 | * @version 1.0 |
14 | 14 | * <p> |
15 | | - * 消息去重，记录消息ID首次出现时的时间戳， |
16 | | - * 15S后定时任务触发时废除该记录消息ID |
| 15 | + * 消息去重，记录消息ID首次出现时的时间戳， |
| 16 | + * 15S后定时任务触发时废除该记录消息ID |
17 | 17 | * </p> |
18 | 18 | * created on 2022/5/26 1:32 |
19 | 19 | */ |
@@ -34,7 +34,7 @@ public class WxMessageInMemoryDuplicateCheckerSingleton implements WxMessageDupl |
34 | 34 | * 线程池 |
35 | 35 | */ |
36 | 36 | private static final ScheduledThreadPoolExecutor SCHEDULED_THREAD_POOL_EXECUTOR = new ScheduledThreadPoolExecutor(1, |
37 | | - new ThreadFactoryBuilder().setNameFormat("wxMessage-memory-pool-%d").build(), new ThreadPoolExecutor.AbortPolicy()); |
| 37 | + new ThreadFactoryBuilder().setNameFormat("wxMessage-memory-pool-%d").setDaemon(true).build(), new ThreadPoolExecutor.AbortPolicy()); |
38 | 38 |
|
39 | 39 | /** |
40 | 40 | * 消息id->消息时间戳的map. |
@@ -71,7 +71,7 @@ public static WxMessageInMemoryDuplicateCheckerSingleton getInstance() { |
71 | 71 | * 内部类实现单例 |
72 | 72 | */ |
73 | 73 | private static class WxMessageInnerClass { |
74 | | - static final WxMessageInMemoryDuplicateCheckerSingleton CHECKER_SINGLETON = new WxMessageInMemoryDuplicateCheckerSingleton(); |
| 74 | + static final WxMessageInMemoryDuplicateCheckerSingleton CHECKER_SINGLETON = new WxMessageInMemoryDuplicateCheckerSingleton(); |
75 | 75 | } |
76 | 76 |
|
77 | 77 | /** |
|