From 98d120bd0633e4e0717d584cae5514132a18516b Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期四, 18 十二月 2025 13:36:09 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/network/fake/ZyRgvFakeConnect.java | 20 ++++++++++++++++++--
1 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/core/network/fake/ZyRgvFakeConnect.java b/src/main/java/com/zy/core/network/fake/ZyRgvFakeConnect.java
index 5f959b0..ac8cb73 100644
--- a/src/main/java/com/zy/core/network/fake/ZyRgvFakeConnect.java
+++ b/src/main/java/com/zy/core/network/fake/ZyRgvFakeConnect.java
@@ -37,6 +37,7 @@
@Override
public boolean disconnect() {
+ try { executor.shutdownNow(); } catch (Exception ignore) {}
return true;
}
@@ -120,11 +121,17 @@
status.setRgvPos(currentTrackSiteNo);
sleep(1000);
+ if (Thread.currentThread().isInterrupted()) {
+ return;
+ }
}
status.setStatus(RgvStatusType.PUTTING.id);
status.setLoaded(1);
sleep(1000);
+ if (Thread.currentThread().isInterrupted()) {
+ return;
+ }
for (int i = 0; i < targetNavigateNodes.size(); i++) {
NavigateNode navigateNode = targetNavigateNodes.get(i);
@@ -133,9 +140,15 @@
status.setRgvPos(currentTrackSiteNo);
sleep(1000);
+ if (Thread.currentThread().isInterrupted()) {
+ return;
+ }
}
sleep(1000);
+ if (Thread.currentThread().isInterrupted()) {
+ return;
+ }
status.setStatus(RgvStatusType.WAITING.id);
}
@@ -181,6 +194,9 @@
status.setRgvPos(currentTrackSiteNo);
sleep(1000);
+ if (Thread.currentThread().isInterrupted()) {
+ return;
+ }
}
status.setStatus(RgvStatusType.WAITING.id);
}
@@ -194,7 +210,7 @@
try {
Thread.sleep(ms);
} catch (InterruptedException e) {
- e.printStackTrace();
+ Thread.currentThread().interrupt();
}
}
-}
\ No newline at end of file
+}
--
Gitblit v1.9.1