| | |
| | | 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() {
|
| | | }
|
| | |
| | | }
|
| | |
|
| | | public synchronized void remove(Object tag) {
|
| | | try {
|
| | |
|
| | | ioThread.execute(new Runnable() {
|
| | | @Override
|
| | | public void run() {
|
| | |
| | |
|
| | | }
|
| | | });
|
| | | }catch (Exception e){}
|
| | | }
|
| | |
|
| | | public synchronized void remove(Object tag, EventListener listener) {
|
| | | try {
|
| | | ioThread.execute(new Runnable() {
|
| | | @Override
|
| | | public void run() {
|
| | |
| | |
|
| | | }
|
| | | });
|
| | | }catch (Exception e){}
|
| | | }
|
| | |
|
| | |
|
| | |
| | | * @param listener
|
| | | */
|
| | | public synchronized void removeAllTopicsListener(EventListener listener) {
|
| | | try {
|
| | | ioThread.execute(new Runnable() {
|
| | | @Override
|
| | | public void run() {
|
| | |
| | |
|
| | | }
|
| | | });
|
| | | }catch (Exception e){}
|
| | | }
|
| | |
|
| | | public synchronized void clear() {
|