From 0bdae90ac60882b66200925c4fbde405fdb243b3 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期四, 05 六月 2025 10:49:55 +0800
Subject: [PATCH] *
---
src/main/java/com/zy/core/thread/RgvThread.java | 33 +++++++++++++++++++++++++++++++++
1 files changed, 33 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index cd37355..a3c6f6d 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -130,6 +130,15 @@
private void readStatusRgv() {
while (true) {
try {
+ if(!connectRgv){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ initRgv();
+ continue;
+ }
Thread.sleep(20);
// System.out.println("璇荤嚎绋�"+ slave.getId());
@@ -157,6 +166,14 @@
private void taskComplete() {
while (true) {
try {
+ if(!connectRgv){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ continue;
+ }
if (delRgvTask){
writeDelRgvTask();
delRgvTask = false;
@@ -253,6 +270,14 @@
private void taskWalkIssued() {
while (true) {
try {
+ if(!connectRgv){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ continue;
+ }
// 浼戠湢 1 绉�
Thread.sleep(100);
@@ -290,6 +315,14 @@
*/
private void taskIssued() {
while (true) {
+ if(!connectRgv){
+ try {
+ Thread.sleep(1000L);
+ } catch (Exception e){
+
+ }
+ continue;
+ }
RgvRunProtocol rgvRun = RgvRunCache.getRgvRun();
if (!rgvRun.getRgvNo().equals(slave.getId())){
continue;
--
Gitblit v1.9.1