并行流

src/main/java/common/service/impl/ShareIncomeServiceImpl.java

@@ -25,6 +25,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 @Service
 public class ShareIncomeServiceImpl implements ShareIncomeService {
@@ -96,10 +97,16 @@ public class ShareIncomeServiceImpl implements ShareIncomeService {
         DateTime end = new DateTime(endDate);
 
         long start_ = System.currentTimeMillis();
-        for (Contract contract : contracts) {
-
+       /* for (Contract contract : contracts) {
             this.shareIncome4Contract(contract, start, end);
             contract.setMyBodyName(bodiesNameMap.get(contract.getMyBodyCode()));
+        }*/
+
+        try (Stream<Contract> streamContract = contracts.parallelStream()) {
+            streamContract.forEach(v -> {
+                this.shareIncome4Contract(v, start, end);
+                v.setMyBodyName(bodiesNameMap.get(v.getMyBodyCode()));
+            });
         }
         logger.info("计算分摊收入耗时:{}", (System.currentTimeMillis() - start_));