| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 查询是否有可执行任务 |
| | | */ |
| | | public boolean isNowPosRun(Long targetPosition) { |
| | | // lock.readLock().lock(); // 加读锁 |
| | | try { |
| | | List<TaskProtocol> allWalkTaskProtocol = new ArrayList<>(); |
| | | for (TaskProtocol task : cache.values()) { |
| | | long runPos = Math.abs(task.getTargetPosition() - targetPosition); |
| | | if (runPos<50) { |
| | | return true; |
| | | } |
| | | } |
| | | return false; // 返回副本 |
| | | } finally { |
| | | // lock.readLock().unlock(); // 释放读锁 |
| | | } |
| | | } |
| | | /** |
| | | * 查询是否有可执行任务 |
| | | */ |
| | | public TaskProtocol getNowPosRunTask(Long targetPosition) { |
| | | // lock.readLock().lock(); // 加读锁 |
| | | try { |
| | | for (TaskProtocol task : cache.values()) { |
| | | long runPos = Math.abs(task.getTargetPosition() - targetPosition); |
| | | if (runPos<50) { |
| | | return task; |
| | | } |
| | | } |
| | | return null; // 返回副本 |
| | | } finally { |
| | | // lock.readLock().unlock(); // 释放读锁 |
| | | } |
| | | } |
| | | |
| | | } |