From fdcf461fbfa3bcd650685743e891ad3357898f0c Mon Sep 17 00:00:00 2001
From: 562935844@qq.com
Date: 星期四, 31 八月 2023 17:36:50 +0800
Subject: [PATCH] 更新sdk

---
 HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java |   28 +++++++++++++++-------------
 1 files changed, 15 insertions(+), 13 deletions(-)

diff --git a/HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java b/HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java
index bfb38b3..96adb95 100644
--- a/HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java
+++ b/HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java
@@ -1,8 +1,7 @@
 package com.hdl.sdk.common.event;
 
-import androidx.annotation.NonNull;
-import androidx.collection.ArrayMap;
 
+import android.util.ArrayMap;
 
 import com.hdl.sdk.common.utils.LogUtils;
 import com.hdl.sdk.common.utils.ThreadToolUtils;
@@ -10,6 +9,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutorService;
 
 
@@ -21,9 +21,9 @@
 
     private static final List<EventListener> ALL_TOPICS_EVENT = new ArrayList<>();//鎵�鏈変富棰樻秷鎭�
 
-    private static final ArrayMap<Object, List<EventListener>> EVENT = new ArrayMap<>();
+    private static final ConcurrentHashMap<Object, List<EventListener>> EVENT = new ConcurrentHashMap<>();
 
-    private static final ArrayMap<EventListener, Integer> TYPE = new ArrayMap<>();
+    private static final ConcurrentHashMap<EventListener, Integer> TYPE = new ConcurrentHashMap<>();
 
     private static final int MAIN_TYPE = 0;
     private static final int IO_TYPE = 1;
@@ -62,7 +62,7 @@
         }
     }
 
-    public  void registerIo(Object tag, EventListener listener) {
+    public void registerIo(Object tag, EventListener listener) {
         synchronized (this) {
             LogUtils.i("娉ㄥ唽涓婚锛�" + tag);
             if (tag == null) return;
@@ -82,7 +82,7 @@
         }
     }
 
-    public  void remove(Object tag) {
+    public void remove(Object tag) {
         synchronized (this) {
             if (tag == null) {
                 return;
@@ -105,7 +105,7 @@
         }
     }
 
-    public  void remove(Object tag, EventListener listener) {
+    public void remove(Object tag, EventListener listener) {
         synchronized (this) {
             try {
                 if (tag == null || listener == null) {
@@ -125,7 +125,7 @@
         }
     }
 
-    public synchronized void post(Object tag, @NonNull Object o) {
+    public synchronized void post(Object tag, Object o) {
         if (tag == null) {
             LogUtils.i("post tag涓虹┖");
             return;
@@ -147,7 +147,7 @@
                                         listener.onMessage(o);
                                     }
                                 } catch (Exception e) {
-                                    LogUtils.e("post寮傚父1锛�" + e.getMessage());
+//                                    LogUtils.e("post寮傚父1锛�" + e.getMessage());
                                 }
                             }
                         });
@@ -173,17 +173,18 @@
                     });
                 }
             }
-        }catch (Exception e){
+        } catch (Exception e) {
             LogUtils.e("post寮傚父2锛�" + e.getMessage());
         }
     }
 
     /**
      * 娉ㄥ唽鎵�鏈変富棰樻秷鎭殑鐩戝惉
+     *
      * @param listener
      */
     public synchronized void registerAllTopicsListener(EventListener listener) {
-        if(listener==null){
+        if (listener == null) {
             return;
         }
         try {
@@ -191,13 +192,14 @@
                 ALL_TOPICS_EVENT.add(listener);
             }
             TYPE.put(listener, MAIN_TYPE);
-        }catch (Exception e){
+        } catch (Exception e) {
             LogUtils.e("registerAllTopicsListener锛�" + e.getMessage());
         }
     }
 
     /**
      * 鍙栨秷鎵�鏈変富棰樻秷鎭殑鐩戝惉
+     *
      * @param listener
      */
     public synchronized void removeAllTopicsListener(EventListener listener) {
@@ -206,7 +208,7 @@
                 @Override
                 public void run() {
                     try {
-                        if(listener==null){
+                        if (listener == null) {
                             return;
                         }
                         if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {

--
Gitblit v1.8.0