*

lsh

3 天以前 079e0820794e35174dccc549d6012c1111c2fe6e

*

 src/main/java/com/zy/core/MainProcess.java

@@ -53,7 +53,7 @@
                    Thread.sleep(200);

                    // 系统运行状态判断
                    if (!SystemProperties.WCS_RUNNING_STATUS.get()) {
                    if (SystemProperties.WCS_RUNNING_STATUS.get()) {
                        continue;
                    }


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

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

                    }
                    continue;
                }
                int step = 1;
                Task task = MessageQueue.poll(SlaveType.Rgv, slave.getId());
                if (task != null) {
@@ -162,6 +170,14 @@
    private void readStatusRgv() {
        while (true) {
            try {
                if(!connectRgv){
                    try {
                        Thread.sleep(1000L);
                    } catch (Exception e){

                    }
                    continue;
                }
                Thread.sleep(40);
                readStatus();


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

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

                    }
                    continue;
                }
                int step = 1;
                Task task = MessageQueue.poll(SlaveType.Ste, slave.getId());
                if (task != null) {
@@ -130,6 +138,14 @@
    private void readStatusSte() {
        while (true) {
            try {
                if(!connectSte){
                    try {
                        Thread.sleep(1000L);
                    } catch (Exception e){

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