爆！Java高級特性之Stream API詳解

Java 8引入的Stream API可以說是一個革命性的特性,讓我們告別了又臭又長的for循環,迎來了函數式編程的春天。今天就讓我們來一起深入了解這個讓人又愛又恨的Stream API吧!

什么是Stream?

Stream就像一個高級的迭代器,允許我們以聲明式方式處理數據集合。它可以讓我們用一種類似SQL查詢的方式來操作Java對象。Stream API結合了函數式編程的概念,大大簡化了集合操作。

簡單來說,Stream就是數據流。我們可以imagin它就像一條傳送帶,在上面放上要處理的元素,然后讓它流過一系列的操作。

創建Stream

創建Stream的方式有很多,我們來看幾種常見的:

1. 從Collection創建

List<String> list = Arrays.asList("a", "b", "c");
Stream<String> stream = list.stream();

2. 從數組創建

String[] arr = {"a", "b", "c"};
Stream<String> stream = Arrays.stream(arr);

3. 使用Stream.of()

Stream<String> stream = Stream.of("a", "b", "c");

4. 生成無限流

Stream<Integer> infiniteStream = Stream.iterate(0, n -> n + 2);

看到這里,有些同學可能會說:"這有什么了不起的?我用for循環一樣可以啊!"別急,好戲才剛剛開始。

Stream操作

Stream API提供了豐富的中間操作和終端操作,讓我們可以方便地對數據進行各種轉換和匯總。

中間操作

中間操作會返回一個新的Stream,我們可以將多個中間操作連接起來形成一個查詢。常見的中間操作包括:

1. filter: 過濾元素

Stream<String> filtered = stream.filter(s -> s.startsWith("a"));

2. map: 轉換元素

Stream<String> mapped = stream.map(String::toUpperCase);

3. flatMap: 將流中的每個元素轉換為一個流,然后把所有流連接起來

Stream<String> flatMapped = stream.flatMap(s -> Arrays.stream(s.split("")));

4. distinct: 去重

Stream<String> distinct = stream.distinct();

5. sorted: 排序

Stream<String> sorted = stream.sorted();

6. peek: 對每個元素執行操作并返回一個新的Stream

Stream<String> peeked = stream.peek(System.out::println);

終端操作

終端操作會遍歷流以生成一個結果或副作用。在終端操作之后,流就被使用"光"了,無法再被操作。常見的終端操作包括:

1. forEach: 遍歷每個元素

stream.forEach(System.out::println);

2. count: 返回流中元素的個數

long count = stream.count();

3. collect: 將流轉換為其他形式

List<String> list = stream.collect(Collectors.toList());

4. reduce: 將流中元素組合起來

Optional<String> reduced = stream.reduce((s1, s2) -> s1 + s2);

5. anyMatch, allMatch, noneMatch: 匹配操作

boolean anyStartsWithA = stream.anyMatch(s -> s.startsWith("a"));

6. findFirst, findAny: 查找操作

Optional<String> first = stream.findFirst();

看到這里,有些同學可能會說:"哇,這么多操作,我腦子都暈了!"別擔心,讓我們來看一個實際的例子,你就會發現Stream API有多香了。

實戰案例

假設我們有一個Person類:

class Person {String name;int age;// 構造函數、getter和setter省略
}

現在我們有一個List<Person>,我們想要找出所有年齡大于18歲的人的名字,按字母順序排序,并且只取前3個。用傳統的方式,我們可能會這樣寫:

List<String> result = new ArrayList<>();
for (Person p : persons) {if (p.getAge() > 18) {result.add(p.getName());}
}
Collections.sort(result);
if (result.size() > 3) {result = result.subList(0, 3);
}

看起來不算太糟?那讓我們來看看用Stream API怎么寫:

List<String> result = persons.stream().filter(p -> p.getAge() > 18).map(Person::getName).sorted().limit(3).collect(Collectors.toList());

怎么樣?是不是感覺整個世界都清爽了?這就是Stream API的魅力所在!它讓我們的代碼更加簡潔、易讀,而且更加聲明式。我們告訴程序"我們想要什么",而不是"怎么去做"。

性能考慮

說到這里,可能有些同學會問:“Stream這么好用,是不是意味著我們應該到處使用它?”

嗯…這個問題問得好!雖然Stream API非常強大,但它并不是萬能的。在某些情況下,傳統的迭代可能會更快。特別是當我們處理的是基本類型(如int, long)時,使用Stream可能會帶來裝箱和拆箱的開銷。

另外,Stream的延遲執行特性也是把雙刃劍。它可以幫我們優化操作,避免不必要的計算。但如果使用不當,也可能導致性能問題。比如:

Stream<Integer> stream = Stream.iterate(0, i -> i + 1);
stream.filter(i -> i % 2 == 0).map(i -> i * 2).limit(10).forEach(System.out::println);

這段代碼看起來沒什么問題,但實際上它的效率并不高。因為iterate生成的是一個無限流,filter和map操作會被反復執行,直到找到10個符合條件的元素。

一個更高效的寫法是:

Stream.iterate(0, i -> i + 2).map(i -> i * 2).limit(10).forEach(System.out::println);

這樣我們就避免了不必要的過濾操作。

并行流

Stream API的另一個強大特性是可以輕松地實現并行處理。只需要調用parallel()方法,就可以將串行流轉換為并行流:

List<String> result = persons.parallelStream().filter(p -> p.getAge() > 18).map(Person::getName).sorted().limit(3).collect(Collectors.toList());

看起來很誘人是不是?但請記住,并行并不總是更快。在數據量較小或者操作較簡單的情況下,并行處理的開銷可能會超過其帶來的收益。所以在使用并行流之前,一定要進行充分的測試和基準比較。

總結

Stream API無疑是Java 8中最重要的特性之一。它為我們提供了一種新的數據處理方式,讓我們的代碼更加簡潔、易讀、高效。但就像所有的技術一樣,它也不是銀彈。我們需要理解它的工作原理,合理地使用它,才能真正發揮它的威力。

最后,送大家一句話:“Stream API很酷,但請記住,過度使用可能會導致代碼可讀性下降。保持簡單,保持清晰,這才是編程的真諦。”

好了,今天的課程就到這里。如果你覺得這篇文章對你有幫助,別忘了點贊收藏哦!下次我們再來探討其他Java高級特性。碼字不易,你的支持就是我創作的動力!

海碼面試 小程序

包含最新面試經驗分享，面試真題解析，全棧2000+題目庫，前后端面試技術手冊詳解；無論您是校招還是社招面試還是想提升編程能力，都能從容面對~

好了,今天的課程就到這里。如果你覺得這篇文章對你有幫助,別忘了點贊收藏哦!下次我們再來探討其他Java高級特性。碼字不易,你的支持就是我創作的動力!

海碼面試 小程序

包含最新面試經驗分享，面試真題解析，全棧2000+題目庫，前后端面試技術手冊詳解；無論您是校招還是社招面試還是想提升編程能力，都能從容面對~

[外鏈圖片轉存中…(img-TlNCRLSu-1720181315161)]