src/main/java/com/zy/core/cache/TaskProtocolCache.java
@@ -137,5 +137,22 @@ // 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(); // 释放读锁 } } }