增加判断json数据格式

hxb

2022-03-21 0188dee359636723190f0f67a6b674b7b08f7bef

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

@@ -27,7 +27,7 @@
    private static final int MAIN_TYPE = 0;

    private static final int IO_TYPE = 1;



    private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(2);

    private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(3);



    private EventDispatcher() {

    }

@@ -63,43 +63,48 @@
    }



    public synchronized void remove(Object tag) {

        ioThread.execute(new Runnable() {

            @Override

            public void run() {

                try {

                    if (EVENT.containsKey(tag)) {

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

                        for (EventListener eventListener : list) {

                            TYPE.remove(eventListener);

        try {



            ioThread.execute(new Runnable() {

                @Override

                public void run() {

                    try {

                        if (EVENT.containsKey(tag)) {

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

                            for (EventListener eventListener : list) {

                                TYPE.remove(eventListener);

                            }

                            EVENT.remove(tag);

                        }

                        EVENT.remove(tag);

                    } catch (Exception ignored) {



                    }

                } catch (Exception ignored) {



                }



            }

        });

            });

        }catch (Exception e){}

    }



    public synchronized void remove(Object tag, EventListener listener) {

        ioThread.execute(new Runnable() {

            @Override

            public void run() {

                try {

                    if (EVENT.containsKey(tag)) {

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

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

                            TYPE.remove(listener);

                            ev.remove(listener);

        try {

            ioThread.execute(new Runnable() {

                @Override

                public void run() {

                    try {

                        if (EVENT.containsKey(tag)) {

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

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

                                TYPE.remove(listener);

                                ev.remove(listener);

                            }

                        }

                    } catch (Exception ignored) {



                    }

                } catch (Exception ignored) {



                }



            }

        });

            });

        }catch (Exception e){}

    }





@@ -150,20 +155,22 @@
     * @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);

        try {

            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) {



                    }

                } catch (Exception ignored) {



                }



            }

        });

            });

        }catch (Exception e){}

    }



    public synchronized void clear() {