2021-11-15 1.更新

JLChen

2021-11-15 1323c0b3463c5486be9d5e5310782aeb9023697c

 HDLSDK/hdl-common/src/main/java/com/hdl/sdk/common/event/EventDispatcher.java

@@ -18,6 +18,8 @@
 */

public class EventDispatcher {



    private static final List<EventListener> ALL_TOPICS_EVENT = new ArrayList<>();//所有主题消息



    private static final ArrayMap<Object, List<EventListener>> EVENT = new ArrayMap<>();



    private static final ArrayMap<EventListener, Integer> TYPE = new ArrayMap<>();

@@ -100,6 +102,7 @@
        });

    }





    public synchronized void post(Object tag, @NonNull Object o) {

        if (EVENT.containsKey(tag)) {

            List<EventListener> list = EVENT.get(tag);

@@ -116,9 +119,55 @@
                }

            }

        }

        //所有主题的Listener通知

        if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {

            for (EventListener listener : ALL_TOPICS_EVENT) {

                ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {

                    @Override

                    public void run() {

                        if (listener != null) {

                            listener.onMessage(o);

                        }

                    }

                });

            }

        }

    }



    /**

     * 注册所有主题消息的监听

     * @param listener

     */

    public synchronized void registerAllTopicsListener(EventListener listener) {

        if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.contains(listener)) {

            ALL_TOPICS_EVENT.add(listener);

        }

        TYPE.put(listener, MAIN_TYPE);

    }



    /**

     * 取消所有主题消息的监听

     * @param listener

     */

    public synchronized void removeAllTopicsListener(EventListener listener) {

        ioThread.execute(new Runnable() {

            @Override

            public void run() {

                try {

                    if (ALL_TOPICS_EVENT != null && !ALL_TOPICS_EVENT.isEmpty()) {

                        TYPE.remove(listener);

                        ALL_TOPICS_EVENT.remove(listener);

                    }

                } catch (Exception ignored) {



                }



            }

        });

    }



    public synchronized void clear() {

        ALL_TOPICS_EVENT.clear();

        EVENT.clear();

        TYPE.clear();

    }