*

lsh

2025-06-05 0bdae90ac60882b66200925c4fbde405fdb243b3

*

 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;

 src/main/java/com/zy/core/thread/SiemensDevpThread.java

@@ -185,6 +185,14 @@
    private void writeStatusDev() {
        while (true) {
            try {
                if(!connectDev){
                    try {
                        Thread.sleep(1000L);
                    } catch (Exception e){

                    }
                    continue;
                }
                int step = 1;
                Task task = MessageQueue.poll(SlaveType.Devp, slave.getId());
                if (task != null) {
@@ -214,6 +222,15 @@
    private void readStatusDev() {
        while (true) {
            try {
                if(!connectDev){
                    try {
                        Thread.sleep(1000L);
                    } catch (Exception e){

                    }
                    initSite();
                    continue;
                }
                Thread.sleep(50);
//                System.out.println("读线程"+ slave.getId());