| | |
| | | public void run() { |
| | | connect(); |
| | | close(); |
| | | while (true) { |
| | | try { |
| | | Task task = MessageQueue.poll(SlaveType.Led, slave.getId()); |
| | | if (task != null) { |
| | | switch (task.getStep()) { |
| | | // 写数据 |
| | | case 1: |
| | | write((List<LedCommand>)task.getData()); |
| | | break; |
| | | // 复位 |
| | | case 2: |
| | | reset(); |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | } |
| | | |
| | | Thread.sleep(400); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | // while (true) { |
| | | // try { |
| | | // Task task = MessageQueue.poll(SlaveType.Led, slave.getId()); |
| | | // if (task != null) { |
| | | // switch (task.getStep()) { |
| | | // // 写数据 |
| | | // case 1: |
| | | // write((List<LedCommand>)task.getData()); |
| | | // break; |
| | | // // 复位 |
| | | // case 2: |
| | | // reset(); |
| | | // break; |
| | | // default: |
| | | // break; |
| | | // } |
| | | // } |
| | | // |
| | | // Thread.sleep(400); |
| | | // } catch (Exception e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // } |
| | | } |
| | | |
| | | private void write(List<LedCommand> list) throws Bx5GException { |