From 907f9314657fd0554fecda06e919b98768b0aeea Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期三, 11 十月 2023 18:00:56 +0800
Subject: [PATCH] 2023年10月11日18:00:50
---
HDLLinkLocalSdk/src/main/java/com/hdl/sdk/link/common/event/EventDispatcher.java | 27 ++++++++++++++++-----------
1 files changed, 16 insertions(+), 11 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 5f01513..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,8 +136,9 @@
/**
* 浜嬩欢鍒嗗彂鍣紝鍒嗗彂鎵�鏈夊湪鎺ュ彛鍒楄〃涓殑浜嬩欢
+ *
* @param topicTag -
- * @param o -
+ * @param o -
*/
public synchronized void post(String topicTag, final Object o) {
try {
@@ -171,13 +173,13 @@
// ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
// @Override
// public void run() {
- if (listener != null) {
- listener.onMessage(o);
- }
+ 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