wjc
2025-04-09 87cd5df70918e6ba1af849c5f026d3719bfdb1ac
sdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
@@ -156,26 +156,26 @@
     */
    public synchronized void post(String topicTag, @NonNull Object o) {
        try {
            LogUtils.e("EventDispatcher", "===15");
//            LogUtils.e("EventDispatcher", "===15");
            for (String key : EVENT.keySet()) {
                if (!isMatch(key, topicTag)) {
                    continue;
                }
                LogUtils.e("EventDispatcher", "===16");
//                LogUtils.e("EventDispatcher", "===16");
                List<EventListener> list = EVENT.get(key);
                if (list != null && !list.isEmpty()) {
                    for (EventListener listener : list) {
                        if(listener==null){
                            continue;
                        }
                        LogUtils.e("EventDispatcher", "===17");
//                        LogUtils.e("EventDispatcher", "===17");
                        //需要异步回调的
                        if(ASYNC_EVENT.contains(listener)) {
                            LogUtils.e("EventDispatcher", "===18");
//                            LogUtils.e("EventDispatcher", "===18");
                            runOnSubThread(listener,o);
                        }
                        else {
                            LogUtils.e("EventDispatcher", "===19");
//                            LogUtils.e("EventDispatcher", "===19");
                            runOnUIThread(listener,o);
                        }
                    }
@@ -185,12 +185,12 @@
            if (ALL_TOPICS_EVENT == null || ALL_TOPICS_EVENT.isEmpty()) {
                return;
            }
            LogUtils.e("EventDispatcher", "===20");
//            LogUtils.e("EventDispatcher", "===20");
            //开发分发事件
            for (EventListener listener : ALL_TOPICS_EVENT) {
                runOnUIThread(listener, o);
            }
            LogUtils.e("EventDispatcher", "===21");
//            LogUtils.e("EventDispatcher", "===21");
        }catch (Exception e){
            LogUtils.e(e.getMessage());
        }
@@ -210,7 +210,7 @@
            @Override
            public void run() {
                try {
                    LogUtils.e("EventDispatcher", "===22");
//                    LogUtils.e("EventDispatcher", "===22");
                    eventListener.onMessage(o);
                } catch (Exception e) {
                    LogUtils.e("runOnSubThread数据异常", o + " " + e.getMessage());
@@ -232,7 +232,7 @@
            @Override
            public void run() {
                try {
                    LogUtils.e("EventDispatcher", "===23");
//                    LogUtils.e("EventDispatcher", "===23");
                    eventListener.onMessage(o);
                } catch (Exception e) {
                    LogUtils.e("runOnUIThread数据异常", o + " " + e.getMessage());