浏览代码

thread safe collection

dengjia 4 月之前
父节点
当前提交
9d5344aad2

+ 3 - 5
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/manager/WmPackageManager.java

@@ -1204,7 +1204,7 @@ public class WmPackageManager {
       Map<String, List<Map<String, Object>>> pkg2CheckListMap =
       Map<String, List<Map<String, Object>>> pkg2CheckListMap =
           checkBatch.stream().collect(Collectors.groupingBy((row) -> row.get("pkg_id").toString()));
           checkBatch.stream().collect(Collectors.groupingBy((row) -> row.get("pkg_id").toString()));
 
 
-      pkgBatch.parallelStream()
+      List<WmScorePackageCheckStatusExcelModel> resultBatch = pkgBatch.parallelStream()
           .map(
           .map(
               pkg -> {
               pkg -> {
                 WmScorePackageCheckStatusExcelModel model =
                 WmScorePackageCheckStatusExcelModel model =
@@ -1363,10 +1363,8 @@ public class WmPackageManager {
                         todos[2] + todos[3] + todos[8] + todos[9] + todos[5] + todos[6]));
                         todos[2] + todos[3] + todos[8] + todos[9] + todos[5] + todos[6]));
                 return model;
                 return model;
               })
               })
-          .forEach(
-              model -> {
-                result.add(model);
-              });
+          .collect(Collectors.toList());
+      result.addAll(resultBatch);
     }
     }
 
 
     return result;
     return result;