使用并行流,提高大量节点场景下的性能;

This commit is contained in:
emptypoint 2022-09-18 21:07:15 +08:00
parent 28f6a76933
commit 03a2579984

View File

@ -321,7 +321,7 @@ public class EasyStream<T> extends AbstractEnhancedWrappedStream<T, EasyStream<T
final Map<R, List<T>> pId2ChildrenMap = of(nodeList).group(pIdGetter); final Map<R, List<T>> pId2ChildrenMap = of(nodeList).group(pIdGetter);
List<T> parents = ListUtil.of(); List<T> parents = ListUtil.of();
for (T node : nodeList) { of(nodeList, true).forEach(node -> {
if (parentPredicate.test(node)) { if (parentPredicate.test(node)) {
parents.add(node); parents.add(node);
} }
@ -330,7 +330,7 @@ public class EasyStream<T> extends AbstractEnhancedWrappedStream<T, EasyStream<T
if (children != null) { if (children != null) {
childrenSetter.accept(node, children); childrenSetter.accept(node, children);
} }
} });
return parents; return parents;
} }