From 6e8e367b18855e3003026fdd2b04909467270a59 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A2=81=E6=98=BE=E4=BC=98?= <237809796@qq.com>
Date: Fri, 12 Nov 2021 10:36:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9AeventMap=20=E4=BD=BF?=
 =?UTF-8?q?=E7=94=A8=20ConcurrentHashMap?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/zdemo/AbstractConsumer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java
index 661d165..db3e02b 100644
--- a/src/com/zdemo/AbstractConsumer.java
+++ b/src/com/zdemo/AbstractConsumer.java
@@ -4,9 +4,9 @@ import org.redkale.convert.json.JsonConvert;
 import org.redkale.util.TypeToken;
 
 import javax.annotation.Resource;
-import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Consumer;
 
 /**
@@ -20,7 +20,7 @@ public abstract class AbstractConsumer implements IConsumer {
     @Resource(name = "APP_NAME")
     protected String APP_NAME = "";
 
-    private Map<String, EventType> eventMap = new HashMap<>();
+    private Map<String, EventType> eventMap = new ConcurrentHashMap<>();
 
     protected abstract String getGroupid();