autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-09 04:19:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

修正线程前缀

Browse Source
This commit is contained in:
三丙
2024-10-11 14:37:42 +08:00
parent 3ec2f97933
commit 698f4f9b6d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/config/ShardingThreadPool.java
View File

@@ -79,7 +79,7 @@ public class ShardingThreadPool {
int partition = hash(hashFunction, hashKey); int partition = hash(hashFunction, hashKey);
EXECUTOR_SERVICE_MAP.computeIfAbsent(partition % parallelism, EXECUTOR_SERVICE_MAP.computeIfAbsent(partition % parallelism,
p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads-" + p))) p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads" + p)))
.execute(runnable); .execute(runnable);
} }
} }