| | |
| | | this.consumerExecutor.execute(() -> { |
| | | while (!Thread.currentThread().isInterrupted()) { |
| | | try { |
| | | Thread.sleep(50); |
| | | Thread.sleep(10); |
| | | List<UnlockPathTask> tasks = new ArrayList<>(); |
| | | // if unlockTaskQueue was empty, then block |
| | | tasks.add(unlockTaskQueue.take()); |
| | |
| | | |
| | | String agvNo = task.getAgvNo(); |
| | | int[] codeMatrixIdx = mapDataDispatcher.getCodeMatrixIdx(lev, task.getCodeData()); |
| | | |
| | | if(codeMatrixIdx==null){ |
| | | return new ArrayList<>(); |
| | | } |
| | | DynamicNode dynamicNode = dynamicMatrix[codeMatrixIdx[0]][codeMatrixIdx[1]]; |
| | | int serial = dynamicNode.getSerial(); |
| | | |