From 9efc5cef6ff75da58fe450add20ffab044e74b54 Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期四, 18 一月 2024 09:59:33 +0800
Subject: [PATCH] 2024年01月18日09:59:27

---
 HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java |   39 ++++++++++++++++++++++-----------------
 1 files changed, 22 insertions(+), 17 deletions(-)

diff --git a/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java b/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
index 4076aa7..256bcb7 100644
--- a/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
+++ b/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
@@ -24,7 +24,7 @@
 
     private static final LockList<EventListener> ALL_TOPICS_EVENT = new LockList<EventListener>();//鎵�鏈変富棰樻秷鎭�
 
-//    private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
+    //    private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
     private static final LockArrayMap<String, List<EventListener>> EVENT = new LockArrayMap<String, List<EventListener>>();
 
     private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(2);
@@ -99,7 +99,7 @@
                         if (ev != null && !ev.isEmpty()) {
 //                            TYPE.remove(listener);
                             ev.remove(listener);
-                            LogUtils.i(String.format("绉婚櫎璁㈤槄涓婚:%s,褰撳墠鍥炶皟鏁伴噺:%s",tag,ev.size()));
+                            LogUtils.i(String.format("绉婚櫎璁㈤槄涓婚:%s,褰撳墠鍥炶皟鏁伴噺:%s", tag, ev.size()));
                         }
                     }
                 } catch (Exception e) {
@@ -112,11 +112,12 @@
 
     /**
      * 涓や釜涓婚鏄惁鍖归厤
-     * @param desString 瀛楀吀涓殑涓婚
+     *
+     * @param desString    瀛楀吀涓殑涓婚
      * @param sourceString 鎺ユ敹鍒扮殑涓婚
      * @return
      */
-    boolean isMatch(String desString,String sourceString) {
+    boolean isMatch(String desString, String sourceString) {
         String[] des = desString.split("/");
         String[] source = sourceString.split("/");
         if (des.length != source.length) {
@@ -135,10 +136,11 @@
 
     /**
      * 浜嬩欢鍒嗗彂鍣紝鍒嗗彂鎵�鏈夊湪鎺ュ彛鍒楄〃涓殑浜嬩欢
+     *
      * @param topicTag -
-     * @param o -
+     * @param o        -
      */
-    public synchronized void post(String topicTag, @NonNull Object o) {
+    public synchronized void post(String topicTag, final Object o) {
         try {
             for (String key : EVENT.keySet()) {
                 if (!isMatch(key, topicTag)) {
@@ -168,16 +170,16 @@
             }
             //寮�鍙戝垎鍙戜簨浠�
             for (EventListener listener : ALL_TOPICS_EVENT) {
-                ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
-                    @Override
-                    public void run() {
-                        if (listener != null) {
-                            listener.onMessage(o);
-                        }
-                    }
-                });
+//                ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
+//                    @Override
+//                    public void run() {
+                if (listener != null) {
+                    listener.onMessage(o);
+                }
+//                    }
+//                });
             }
-        }catch (Exception e){
+        } catch (Exception e) {
             LogUtils.e(e.getMessage());
         }
 
@@ -189,8 +191,10 @@
     public synchronized void filePost() {
         //TODO
     }
+
     /**
      * 娉ㄥ唽鎵�鏈変富棰樻秷鎭殑鐩戝惉
+     *
      * @param listener
      */
     public synchronized void registerAllTopicsListener(EventListener listener) {
@@ -206,6 +210,7 @@
 
     /**
      * 鍙栨秷鎵�鏈変富棰樻秷鎭殑鐩戝惉
+     *
      * @param listener
      */
     public synchronized void removeAllTopicsListener(EventListener listener) {
@@ -224,13 +229,13 @@
         });
     }
 
-    public synchronized void clear() {
+    private synchronized void clear() {
         ALL_TOPICS_EVENT.clear();
         EVENT.clear();
 //        TYPE.clear();
     }
 
-    public synchronized void release() {
+    private synchronized void release() {
         clear();
         ioThread.shutdownNow();
     }

--
Gitblit v1.8.0