diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/FastStream.java b/hutool-core/src/main/java/cn/hutool/core/stream/FastStream.java index fad246885..0916995bf 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/FastStream.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/FastStream.java @@ -538,10 +538,10 @@ public class FastStream implements Stream, Iterable { // 第一次出现的key返回true return null == exists.putIfAbsent(key, Boolean.TRUE); } - })).parallel(isParallel()); + })).parallel(); } else { Set exists = new HashSet<>(); - return of(stream.filter(e -> exists.add(keyExtractor.apply(e)))).parallel(isParallel()); + return of(stream.filter(e -> exists.add(keyExtractor.apply(e)))); } } @@ -1004,7 +1004,7 @@ public class FastStream implements Stream, Iterable { public FastStream reverse() { List list = toList(); Collections.reverse(list); - return FastStream.of(list, isParallel()); + return of(list, isParallel()); } /** @@ -1403,7 +1403,9 @@ public class FastStream implements Stream, Iterable { if (isParallel()) { resStream = toList().stream(); } - return of(resStream.map(e -> zipper.apply(e, iterator.hasNext() ? iterator.next() : null))); + final FastStream newStream = of(resStream.map(e -> zipper.apply(e, iterator.hasNext() ? iterator.next() : null))); + newStream.parallel(isParallel()); + return newStream; } /**