From 0372b9a6bfd8ef6b63067466dd9e0a8f99167bc0 Mon Sep 17 00:00:00 2001
From: "autumn.g@foxmail.com" <autumn.g@foxmail.com>
Date: Mon, 18 Sep 2023 16:16:02 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E5=85=A8=E5=B1=80map?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/jsowell/common/enums/ykc/PileChannelEntity.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java b/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java
index 755f70cac..a75353ba5 100644
--- a/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java
+++ b/jsowell-common/src/main/java/com/jsowell/common/enums/ykc/PileChannelEntity.java
@@ -3,13 +3,17 @@ package com.jsowell.common.enums.ykc;
 import io.netty.channel.Channel;
 
 import java.util.HashMap;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * 桩编号和channel的关联关系处理 entity
  */
 public class PileChannelEntity {
 
-    private static HashMap<String, Channel> manager = new HashMap<>();
+    /**
+     * 管理一个全局map，保存连接进服务端的通道数量
+     */
+    private static final ConcurrentHashMap<String, Channel> manager = new ConcurrentHashMap<>();
  
     public static void put(String pileSn, Channel channel) {
         manager.put(pileSn, channel);