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

线程池命名错误

Browse Source
This commit is contained in:
三丙
2024-10-14 17:46:22 +08:00
parent 86614a5a92
commit 103f782ddf
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -38,7 +38,7 @@ public class ShardingThreadPool {
private HashFunction hashFunction; private HashFunction hashFunction;
private final Map<Integer, ExecutorService> EXECUTOR_SERVICE_MAP = new ConcurrentHashMap<>(8); private final Map<Integer, ExecutorService> executorServiceMap = new ConcurrentHashMap<>(8);
@PostConstruct @PostConstruct
public void init() { public void init() {
@@ -47,7 +47,7 @@ public class ShardingThreadPool {
@PreDestroy @PreDestroy
public void destroy() { public void destroy() {
for (ExecutorService executorService : EXECUTOR_SERVICE_MAP.values()) { for (ExecutorService executorService : executorServiceMap.values()) {
executorService.shutdownNow(); executorService.shutdownNow();
log.info("Sharding Thread [{}] Shutdown completed.", executorService); log.info("Sharding Thread [{}] Shutdown completed.", executorService);
} }
@@ -55,7 +55,7 @@ public class ShardingThreadPool {
@Scheduled(fixedDelayString = "${thread-pool.sharding.stats-print-interval-ms:10000}") @Scheduled(fixedDelayString = "${thread-pool.sharding.stats-print-interval-ms:10000}")
public void printStats() { public void printStats() {
EXECUTOR_SERVICE_MAP.forEach((k, v) -> { executorServiceMap.forEach((k, v) -> {
ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) v; ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) v;
@@ -78,8 +78,8 @@ public class ShardingThreadPool {
public void execute(UUID hashKey, TracerRunnable runnable) { public void execute(UUID hashKey, TracerRunnable runnable) {
int partition = hash(hashFunction, hashKey); int partition = hash(hashFunction, hashKey);
EXECUTOR_SERVICE_MAP.computeIfAbsent(partition % parallelism, executorServiceMap.computeIfAbsent(Math.abs(partition % parallelism),
p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads-%d" + p))) p -> Executors.newFixedThreadPool(1, JCPPThreadFactory.forName("sharding-threads-" + p)))
.execute(runnable); .execute(runnable);
} }
} }

4
jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/v150/YunKuaiChongV15ProtocolMessageProcessor.java
View File

@@ -102,7 +102,7 @@ public class YunKuaiChongV15ProtocolMessageProcessor extends ProtocolMessageProc
int seqNo = in.readUnsignedShortLE(); int seqNo = in.readUnsignedShortLE();
// 加密标志 // 加密标志
int encrpyFlag = in.readUnsignedByte(); int encryptFlag = in.readUnsignedByte();
// 帧类型标志 // 帧类型标志
int frameType = in.readUnsignedByte(); int frameType = in.readUnsignedByte();
@@ -154,7 +154,7 @@ public class YunKuaiChongV15ProtocolMessageProcessor extends ProtocolMessageProc
message.setHead(startFlag); message.setHead(startFlag);
message.setDataLength(dataLength); message.setDataLength(dataLength);
message.setSequenceNumber(seqNo); message.setSequenceNumber(seqNo);
message.setEncryptionFlag(encrpyFlag); message.setEncryptionFlag(encryptFlag);
message.setCmd(frameType); message.setCmd(frameType);
message.setMsgBody(msgBody); message.setMsgBody(msgBody);
message.setCheckSum(checkSum); message.setCheckSum(checkSum);