src/main/java/com/zy/core/cache/TaskProtocolCache.java
@@ -155,4 +155,32 @@ } } /** * 查询是否有可执行任务 */ public TaskProtocol getNowPosRunTask2() { // lock.readLock().lock(); // 加读锁 try { for (TaskProtocol task : cache.values()) { if (task.getTaskStatus()==1) { return task; } } for (TaskProtocol task : cache.values()) { if (task.getTaskStatus()==2) { return task; } } for (TaskProtocol task : cache.values()) { if (task.getTaskStatus()==3) { return task; } } return null; // 返回副本 } finally { // lock.readLock().unlock(); // 释放读锁 } } }