*

lsh

2 天以前 e73925f9f3a4be298aac89251f317cab5c14ac04

 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();

@@ -407,18 +423,18 @@
    /******************************************************************************************/
    /**************************************** 测试专用 *****************************************/
    /*****************************************************************************************/
    public static void main(String[] args) throws InterruptedException {
        RgvSlave slave = new RgvSlave();
        slave.setId(1);
        slave.setIp("192.168.6.9");
        slave.setRack(0);
        slave.setSlot(0);
        RgvThread rgvThread = new RgvThread(slave);
        rgvThread.connect();
        rgvThread.readStatus();
        System.out.println(JSON.toJSONString(rgvThread.rgvProtocol));
        Thread.sleep(3000L);

    }
//    public static void main(String[] args) throws InterruptedException {
//        RgvSlave slave = new RgvSlave();
//        slave.setId(1);
//        slave.setIp("192.168.6.9");
//        slave.setRack(0);
//        slave.setSlot(0);
//        RgvThread rgvThread = new RgvThread(slave);
//        rgvThread.connect();
//        rgvThread.readStatus();
//        System.out.println(JSON.toJSONString(rgvThread.rgvProtocol));
//        Thread.sleep(3000L);
//
//    }

}