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,6 +63,8 @@
    }
    public synchronized void remove(Object tag) {
        try {
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
@@ -80,9 +82,11 @@
            }
        });
        }catch (Exception e){}
    }
    public synchronized void remove(Object tag, EventListener listener) {
        try {
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
@@ -100,6 +104,7 @@
            }
        });
        }catch (Exception e){}
    }
@@ -150,6 +155,7 @@
     * @param listener
     */
    public synchronized void removeAllTopicsListener(EventListener listener) {
        try {
        ioThread.execute(new Runnable() {
            @Override
            public void run() {
@@ -164,6 +170,7 @@
            }
        });
        }catch (Exception e){}
    }
    public synchronized void clear() {