修复任务并发执行次数

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/ocr/service/impl/OcrIdentifyServiceImpl.java

@@ -966,17 +966,22 @@ public class OcrIdentifyServiceImpl extends ServiceImpl<OcrIdentifyMapper, OcrId
         List<TaskModel> waitingTaskList = taskList.stream().filter(t -> t.getTaskStatus().equals("0")).collect(Collectors.toList());
         if (CollectionUtils.isNotEmpty(waitingTaskList)) {
             while (waitingTaskList.size() > 0) {
-                //取第一个任务
+                for (int i = 0; i < 4; i++) {
-                TaskModel taskModel = waitingTaskList.get(0);
+                    if (i>waitingTaskList.size()-1){
-                waitingTaskList.get(0).setTaskStatus("1");
+                        continue;
-                //刷新redis，执行中
+                    }
-                flushTask(taskModel.getTaskId(), 1);
+                    //取第一个任务
-                //执行
+                    TaskModel taskModel = waitingTaskList.get(i);
-                executeTaskp(taskModel);
+                    waitingTaskList.get(i).setTaskStatus("1");
-                //刷新已知任务
+                    //刷新redis，执行中
-                taskList = getTaskList();
+                    flushTask(taskModel.getTaskId(), 1);
-                //刷新待运行任务
+                    //执行
-                waitingTaskList = taskList.stream().filter(t -> t.getTaskStatus().equals("0")).collect(Collectors.toList());
+                    executeTaskp(taskModel);
+                    //刷新已知任务
+                    taskList = getTaskList();
+                    //刷新待运行任务
+                    waitingTaskList = taskList.stream().filter(t -> t.getTaskStatus().equals("0")).collect(Collectors.toList());
+                }
             }
         }
         log.error("任务已全部执行");