Java Stream API 完全指南：從創建到收集器的實戰詳解

Java 8 引入的 java.util.stream.Stream 為集合處理帶來聲明式、函數式風格，極大簡化了篩選、轉換、聚合等操作。本文系統梳理 Stream 特性、創建方式、中間/終端操作、並行流、收集器、常見陷阱與第三方擴展，助你寫出優雅高效的集合代碼。

核心特性

創建 Stream 的 8 種方式

1. Collection.stream() / parallelStream()
2. Arrays.stream(T[]) / Arrays.stream(int[])
3. 靜態工廠：Stream.of()、IntStream.range()、Stream.iterate()、Stream.generate()
4. BufferedReader.lines() 文件行流
5. Files.list/find/walk 路徑流
6. Random.ints() 隨機數流
7. 第三方：BitSet.stream()、Pattern.splitAsStream()、JarFile.stream()
8. 底層：StreamSupport.stream(Spliterator)

中間操作

終端操作

收集器：Collectors 工具類精華

// 轉集合
.toList() / .toSet() / .toCollection(ArrayList::new)

// 字串連接
.joining() / .joining(",") / .joining(",", "[", "]")

// 分組 / 分區
.groupingBy(User::getDept)
.groupingBy(User::getDept, counting())
.partitioningBy(user -> user.getAge() > 18)

// 聚合
.counting() / .summingInt(User::getAge) / .averagingDouble(User::getScore)
.maxBy(Comparator.comparing(User::getAge)) / .minBy(...)
.summarizingInt(User::getAge) // 返回 IntSummaryStatistics

// 降級/轉換
.mapping(User::getName, toList())
.collectingAndThen(toList(), Collections::unmodifiableList)

// 自定義 Collector
Collector.of(supplier, accumulator, combiner, finisher, characteristics)

並行流與性能

• 默認串行，parallelStream() 或 .parallel() 開啟。
• 無狀態、非干擾、關聯性滿足時，並行結果與串行一致。
• 有序流並行可能降低性能（distinct、sorted、limit），可 .unordered() 優化。
• 小數據量、高計算密度任務適合並行；IO 密集、大量同步鎖反而變慢。

常見陷阱

1. 重複消費：stream.forEach(...); stream.count(); → IllegalStateException，需重新獲取流。
2. 修改源集合：終端操作執行期間修改非併發集合 → ConcurrentModificationException。
3. 有狀態 Lambda：並行下結果不確定，保持純函數。
4. 副作用濫用：forEach(list::add) 非線程安全，改用 collect(toList())。
5. 裝箱開銷：基本類型流（IntStream）避免裝箱，性能提升明顯。

第三方擴展推薦

• protonpack：takeWhile、zip、unfold、MapStream 等缺失操作。
• java8-utils：實用輔助方法補充。

總結

Stream API 讓集合處理從「怎麼做」轉向「做什麼」，配合 Lambda 與收集器，代碼更簡潔、可讀、易並行。掌握中間/終端操作分類、收集器組合、並行適用場景與常見坑，是現代 Java 開發必備技能。