src/main/java/com/zy/core/cache/TaskProtocolCache.java
@@ -66,6 +66,14 @@ /** * 获取所有取任务 */ public List<TaskProtocol> getTakeOrPutTaskProtocol(short loaded) { if (loaded == 0){ return getAllTakeTaskProtocol(); } else if (loaded == 1){ return getAllPutTaskProtocol(); } return new ArrayList<>(); } public List<TaskProtocol> getAllTakeTaskProtocol() { // lock.readLock().lock(); // 加读锁 try {