From de2d3696f975cf6e6df2e580bab305fa9859feea Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期四, 26 十月 2023 17:55:36 +0800
Subject: [PATCH] 2023年10月26日17:55:33
---
HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java | 41 +++++++++++++++++++++++------------------
1 files changed, 23 insertions(+), 18 deletions(-)
diff --git a/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java b/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
index 37f8b50..256bcb7 100644
--- a/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
+++ b/HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java
@@ -24,7 +24,7 @@
private static final LockList<EventListener> ALL_TOPICS_EVENT = new LockList<EventListener>();//鎵�鏈変富棰樻秷鎭�
-// private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
+ // private static final ArrayMap<String, List<EventListener>> EVENT = new ArrayMap<>();
private static final LockArrayMap<String, List<EventListener>> EVENT = new LockArrayMap<String, List<EventListener>>();
private static final ExecutorService ioThread = ThreadToolUtils.getInstance().newFixedThreadPool(2);
@@ -99,7 +99,7 @@
if (ev != null && !ev.isEmpty()) {
// TYPE.remove(listener);
ev.remove(listener);
- LogUtils.i(String.format("绉婚櫎璁㈤槄涓婚:%s,褰撳墠鍥炶皟鏁伴噺:%s",tag,ev.size()));
+ LogUtils.i(String.format("绉婚櫎璁㈤槄涓婚:%s,褰撳墠鍥炶皟鏁伴噺:%s", tag, ev.size()));
}
}
} catch (Exception e) {
@@ -112,11 +112,12 @@
/**
* 涓や釜涓婚鏄惁鍖归厤
- * @param desString 瀛楀吀涓殑涓婚
+ *
+ * @param desString 瀛楀吀涓殑涓婚
* @param sourceString 鎺ユ敹鍒扮殑涓婚
* @return
*/
- boolean isMatch(String desString,String sourceString) {
+ boolean isMatch(String desString, String sourceString) {
String[] des = desString.split("/");
String[] source = sourceString.split("/");
if (des.length != source.length) {
@@ -135,10 +136,11 @@
/**
* 浜嬩欢鍒嗗彂鍣紝鍒嗗彂鎵�鏈夊湪鎺ュ彛鍒楄〃涓殑浜嬩欢
- * @param topicTag
- * @param o
+ *
+ * @param topicTag -
+ * @param o -
*/
- public synchronized void post(String topicTag, @NonNull Object o) {
+ public synchronized void post(String topicTag, final Object o) {
try {
for (String key : EVENT.keySet()) {
if (!isMatch(key, topicTag)) {
@@ -168,16 +170,16 @@
}
//寮�鍙戝垎鍙戜簨浠�
for (EventListener listener : ALL_TOPICS_EVENT) {
- ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
- @Override
- public void run() {
- if (listener != null) {
- listener.onMessage(o);
- }
- }
- });
+// ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
+// @Override
+// public void run() {
+ if (listener != null) {
+ listener.onMessage(o);
+ }
+// }
+// });
}
- }catch (Exception e){
+ } catch (Exception e) {
LogUtils.e(e.getMessage());
}
@@ -189,8 +191,10 @@
public synchronized void filePost() {
//TODO
}
+
/**
* 娉ㄥ唽鎵�鏈変富棰樻秷鎭殑鐩戝惉
+ *
* @param listener
*/
public synchronized void registerAllTopicsListener(EventListener listener) {
@@ -206,6 +210,7 @@
/**
* 鍙栨秷鎵�鏈変富棰樻秷鎭殑鐩戝惉
+ *
* @param listener
*/
public synchronized void removeAllTopicsListener(EventListener listener) {
@@ -224,13 +229,13 @@
});
}
- public synchronized void clear() {
+ private synchronized void clear() {
ALL_TOPICS_EVENT.clear();
EVENT.clear();
// TYPE.clear();
}
- public synchronized void release() {
+ private synchronized void release() {
clear();
ioThread.shutdownNow();
}
--
Gitblit v1.8.0