src/main/java/com/zy/core/cache/TaskProtocolCache.java
@@ -117,4 +117,25 @@ } } /** * 查询是否有可执行任务 */ 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(); // 释放读锁 } } }