修改:eventMap 使用 ConcurrentHashMap

This commit is contained in:
梁显优 2021-11-12 10:36:08 +08:00
parent 92c769c708
commit 6e8e367b18

View File

@ -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();