Java Stream API中實現(xiàn)數(shù)據(jù)的并行處理指南
更新時間：2025年10月27日 08:41:38 作者：搜羅萬相
在 Java Stream API 中,實現(xiàn)數(shù)據(jù)的并行處理非常簡單,核心是通過 ??parallelStream() ??? 方法獲取并行流,而非默認的串行流（??stream()??）,本文給大家介紹了Java Stream API中實現(xiàn)數(shù)據(jù)的并行處理的操作方法,需要的朋友可以參考下
引言
在 Java Stream API 中，實現(xiàn)數(shù)據(jù)的并行處理非常簡單，核心是通過 ??parallelStream() ??? 方法獲取并行流，而非默認的串行流（??stream()??）。并行流會自動利用多核 CPU 的優(yōu)勢，將數(shù)據(jù)分成多個子任務(wù)并行執(zhí)行，從而提升大數(shù)據(jù)量處理的效率。
一、并行處理的核心原理
- 并行流（Parallel Stream） ：基于 ?
?Fork/Join?? 框架實現(xiàn)，自動將流中的元素分割成多個子流，由多個線程并行處理，最后合并結(jié)果。 - 無需手動管理線程：開發(fā)者無需創(chuàng)建線程池或處理線程同步，Stream API 內(nèi)部已封裝了并行邏輯。
二、實現(xiàn)并行處理的步驟
- 獲取并行流：通過集合的 ?
?parallelStream()?? 方法（或流的 ??parallel()?? 方法將串行流轉(zhuǎn)為并行流）。 - 執(zhí)行流操作：與串行流相同的鏈?zhǔn)讲僮鳎ㄟ^濾、映射、聚合等），底層會自動并行執(zhí)行。
三、示例代碼
1. 基礎(chǔ)并行處理（對比串行與并行）
import java.util.Arrays;
import java.util.List;
public class ParallelStreamDemo {
public static void main(String[] args) {
// 準(zhǔn)備一個大數(shù)據(jù)量的集合（1000萬個整數(shù)）
List<Integer> numbers = Arrays.asList(new Integer[10_000_000]);
for (int i = 0; i < numbers.size(); i++) {
numbers.set(i, i);
}
// 串行流處理：計算偶數(shù)之和
long start = System.currentTimeMillis();
long serialSum = numbers.stream()
.filter(n -> n % 2 == 0)
.mapToLong(n -> n)
.sum();
long serialTime = System.currentTimeMillis() - start;
System.out.println("串行處理結(jié)果：" + serialSum + "，耗時：" + serialTime + "ms");
// 并行流處理：同樣計算偶數(shù)之和
start = System.currentTimeMillis();
long parallelSum = numbers.parallelStream() // 關(guān)鍵：使用parallelStream()
.filter(n -> n % 2 == 0)
.mapToLong(n -> n)
.sum();
long parallelTime = System.currentTimeMillis() - start;
System.out.println("并行處理結(jié)果：" + parallelSum + "，耗時：" + parallelTime + "ms");
}
}
輸出（示例） ：
串行處理結(jié)果：24999995000000，耗時：120ms 并行處理結(jié)果：24999995000000，耗時：35ms // 并行效率更高（依賴CPU核心數(shù)）
2. 將串行流轉(zhuǎn)為并行流（??parallel()?? 方法）
除了直接使用 ??parallelStream()??，還可以通過 ??parallel()?? 方法將串行流轉(zhuǎn)換為并行流：
List<String> words = Arrays.asList("apple", "banana", "cherry", "date");
// 串行流 → 轉(zhuǎn)為并行流
long count = words.stream()
.parallel() // 切換為并行處理
.filter(word -> word.length() > 5)
.count();
System.out.println("長度大于5的單詞數(shù)：" + count); // 輸出：2（banana、cherry）
四、注意事項
- 線程安全問題
并行流會多線程執(zhí)行操作，若流操作中涉及共享變量的修改（如使用forEach累加全局變量），可能導(dǎo)致線程安全問題。
? 錯誤示例（共享變量不安全）：
int[] sum = {0}; // 共享數(shù)組
numbers.parallelStream()
.forEach(n -> sum[0] += n); // 多線程修改sum[0]，結(jié)果可能不正確
? 正確方式（使用線程安全的聚合操作）：
long sum = numbers.parallelStream()
.mapToLong(n -> n)
.sum(); // sum() 內(nèi)部線程安全
- 并非所有場景都適合并行
- 數(shù)據(jù)量較小時：并行流的線程調(diào)度開銷可能超過并行帶來的收益，效率反而低于串行。
- 操作復(fù)雜度低時：簡單操作（如 ?
?filter?? 簡單判斷）的并行優(yōu)勢不明顯，復(fù)雜操作（如大量計算）更適合并行。 - 流元素有序性（?
?Ordered??）：并行流為提升效率可能打破元素順序（如 ??forEach?? 輸出順序不確定），若需保持順序，可用 ??forEachOrdered??（但會損失部分并行性能）。
- 自定義并行線程池
并行流默認使用Fork/Join框架的公共線程池（ForkJoinPool.commonPool()），若需自定義線程池，可通過ForkJoinPool包裝：
import java.util.concurrent.ForkJoinPool;
ForkJoinPool pool = new ForkJoinPool(4); // 自定義4個核心線程的線程池
long sum = pool.submit(() ->
numbers.parallelStream()
.filter(n -> n % 2 == 0)
.mapToLong(n -> n)
.sum()
).get(); // 阻塞獲取結(jié)果
pool.shutdown(); // 關(guān)閉線程池
五、總結(jié)
- 實現(xiàn)方式：通過 ?
?parallelStream()??? 或 ??stream().parallel()?? 獲取并行流，后續(xù)操作與串行流一致。 - 優(yōu)勢：自動利用多核CPU，提升大數(shù)據(jù)量、復(fù)雜操作的處理效率，無需手動管理線程。
- 注意：避免共享變量修改，數(shù)據(jù)量小或操作簡單時慎用，有序性需求需權(quán)衡性能。
合理使用并行流能顯著優(yōu)化數(shù)據(jù)處理性能，但需根據(jù)具體場景評估是否適用。
到此這篇關(guān)于Java Stream API中實現(xiàn)數(shù)據(jù)的并行處理指南的文章就介紹到這了,更多相關(guān)Java Stream API數(shù)據(jù)并行處理內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java實現(xiàn)將圖片上傳到webapp路徑下 路徑獲取方式
這篇文章主要介紹了Java實現(xiàn)將圖片上傳到webapp路徑下 路徑獲取方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
使用Spring的AbstractRoutingDataSource實現(xiàn)多數(shù)據(jù)源切換示例
這篇文章主要介紹了使用Spring的AbstractRoutingDataSource實現(xiàn)多數(shù)據(jù)源切換示例，具有一定的參考價值，感興趣的小伙伴們可以參考一下。2017-02-02
希爾排序(Shell Sort)是插入排序的一種，是針對直接插入排序算法的改進，是將整個無序列分割成若干小的子序列分別進行插入排序，希爾排序并不穩(wěn)定。該方法又稱縮小增量排序，因DL．Shell于1959年提出而得名。2015-04-04
圖片模糊是圖像處理中的一種常見效果,它通過平均周圍像素的顏色來使圖像變得模糊,下面我們來看看如何使用Swing庫實現(xiàn)圖片模糊效果吧2025-02-02
這篇文章主要介紹了Java?IPage分頁加自定義sql,主要包括引入依賴，impl常規(guī)操作，本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-06-06
本文給大家分享了20個常用的java代碼，都是別人項目中使用過的代碼，這里推薦給大家，有需要的小伙伴可以參考下。2015-05-05
MyBatis-Plus中如何配置加密功能(使用AES算法)
本文將詳細介紹如何實現(xiàn) MyBatis-Plus 中的配置加密功能,并給出相應(yīng)的代碼示例,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-03-03
Java通過value獲取Map中key的三種實現(xiàn)過程
本文介紹了三種通過Value值獲取Map中的Key值的方法：循環(huán)法、Stream方法和ApacheCommonsCollections的BidiMap,每種方法都有其特點和適用場景,選擇哪種方法應(yīng)根據(jù)具體需求來決定2026-01-01
文章講述了如何在Jenkins中設(shè)置定時發(fā)布項目,首先找到要定時啟動的項目,然后點擊配置,選擇構(gòu)建時間,作者分享了這一過程,希望對大家有所幫助2026-01-01
這篇文章主要為大家詳細介紹了java實現(xiàn)幸運抽獎系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-07-07