From d97b98f795e6becf8ce8b042d2fbcec492427e0a Mon Sep 17 00:00:00 2001 From: yvan Date: Mon, 28 Jul 2025 21:36:24 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E7=BB=88=E7=AB=AF=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- servo/src/main/java/com/galaxis/rcs/amr/AmrAgvItem.java | 2 +- servo/src/main/java/com/galaxis/rcs/amr/AmrConnectorThread.java | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/servo/src/main/java/com/galaxis/rcs/amr/AmrAgvItem.java b/servo/src/main/java/com/galaxis/rcs/amr/AmrAgvItem.java index 6c8168a..bf49160 100644 --- a/servo/src/main/java/com/galaxis/rcs/amr/AmrAgvItem.java +++ b/servo/src/main/java/com/galaxis/rcs/amr/AmrAgvItem.java @@ -461,7 +461,7 @@ public abstract class AmrAgvItem extends ExecutorItem { * 停止连接器线程 */ public void stopConnector() { - connectorThread.stop(); + connectorThread.interrupt(); } private static final int speed = 1000; diff --git a/servo/src/main/java/com/galaxis/rcs/amr/AmrConnectorThread.java b/servo/src/main/java/com/galaxis/rcs/amr/AmrConnectorThread.java index 72cc7b8..324ab26 100644 --- a/servo/src/main/java/com/galaxis/rcs/amr/AmrConnectorThread.java +++ b/servo/src/main/java/com/galaxis/rcs/amr/AmrConnectorThread.java @@ -47,6 +47,7 @@ public class AmrConnectorThread extends Thread { // 计算中的任务 List computingTaskList = new ArrayList<>(); while (running.get()) { + Thread.sleep(1); if (paused.get()) { synchronized (pauseLock) { while (paused.get()) { @@ -124,9 +125,9 @@ public class AmrConnectorThread extends Thread { } } catch (InterruptedException e) { - System.out.println("Connector thread interrupted for executor: " + this.ptrAgvItem.getId()); + log.error("Connector thread interrupted for executor: " + this.ptrAgvItem.getId(), e); } finally { - System.out.println("Connector thread stopped for executor: " + this.ptrAgvItem.getId()); + log.info("Connector thread stopped for executor: " + this.ptrAgvItem.getId()); } }