From 1d71c4a6ed388f4086fc1a7b1d99ceeb6ae728b0 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期日, 22 十月 2023 17:29:26 +0800
Subject: [PATCH] #plc2
---
src/main/java/com/zy/core/thread/NyShuttleThread.java | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/NyShuttleThread.java b/src/main/java/com/zy/core/thread/NyShuttleThread.java
index 9ad6f5a..8c24a1b 100644
--- a/src/main/java/com/zy/core/thread/NyShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/NyShuttleThread.java
@@ -414,7 +414,10 @@
// nodes.addAll(command.getNodes());
// }
if (nodes != null) {
- navigateMapData.writeNavigateNodeToRedisMap(nodes, false);//瑙ｉ攣璺緞
+ boolean result = navigateMapData.writeNavigateNodeToRedisMap(nodes, false);//瑙ｉ攣璺緞
+ if (!result) {
+ return false;//瑙ｉ攣澶辫触
+ }
isLock = true;//瑙ｉ攣杩囪矾寰�
}
}
@@ -500,7 +503,10 @@
nodes.addAll(nextNodes);
}
if (nodes != null) {
- navigateMapData.writeNavigateNodeToRedisMap(nodes, true);//鎵�浣跨敤鐨勮矾寰勮繘琛岄攣瀹氱鐢�
+ boolean result = navigateMapData.writeNavigateNodeToRedisMap(nodes, true);//鎵�浣跨敤鐨勮矾寰勮繘琛岄攣瀹氱鐢�
+ if (!result) {
+ return false;//璺緞閿佸畾澶辫触
+ }
}
}
--
Gitblit v1.9.1