| | |
| | | @SuppressWarnings("InfiniteLoopStatement") |
| | | public void run() { |
| | | initRgv(); |
| | | try{ |
| | | Thread.sleep(2000); |
| | | } catch (Exception e){ |
| | | |
| | | } |
| | | connectRgv = this.connect(); |
| | | while(!connectRgv){ |
| | | try { |
| | | connectRgv = this.connect(); |
| | | Thread.sleep(100); |
| | | } catch (Exception e){ |
| | | |
| | | } |
| | | } |
| | | |
| | | // 启动线程自动重连 |
| | | new Thread(this::rgvConnect).start(); |
| | |
| | | initRgv(); |
| | | continue; |
| | | } |
| | | Thread.sleep(20); |
| | | Thread.sleep(50); |
| | | // System.out.println("读线程,小车号"+ slave.getId()+"时间戳:"+System.currentTimeMillis()); |
| | | |
| | | readStatus(); |
| | |
| | | delRgvTask = false; |
| | | continue; |
| | | } |
| | | Thread.sleep(50L); |
| | | Thread.sleep(100L); |
| | | |
| | | OperateResultExOne<byte[]> result = siemensNet.Read("DB100.12", (short) 1); |
| | | boolean[] status = siemensNet.getByteTransform().TransBool(result.Content, 0, 1); |
| | |
| | | continue; |
| | | } |
| | | try { |
| | | Thread.sleep(100); |
| | | Thread.sleep(200); |
| | | rgvRun = RgvRunCache.getRgvRun(); |
| | | // System.out.println(JSON.toJSON(rgvRun)); |
| | | |