摘要

Stream 是對(duì)集合對(duì)象功能的增強(qiáng)，它專(zhuān)注于對(duì)集合對(duì)象進(jìn)行各種非常便利、高效的聚合操作，或者大批量數(shù)據(jù)操作。通常我們需要多行代碼才能完成的操作，借助于Stream流式處理可以很簡(jiǎn)單的實(shí)現(xiàn)。 Stream 不是集合元素，它不是數(shù)據(jù)結(jié)構(gòu)并不保存數(shù)據(jù)，它是有關(guān)算法和計(jì)算的。

創(chuàng)建Steam流

調(diào)用Collection.stream()函數(shù)創(chuàng)建一個(gè)Stream對(duì)象 Stream 接口的靜態(tài)方法 of 可以獲取數(shù)組對(duì)應(yīng)的流

List<String> list = new ArrayList<>();Stream<String> stream1 = list.stream();String[] arr = {'張三', '李四', '王五'};Stream<String> stream2 = Stream.of(arr);

常用方法

void forEach(Consumer<? super T> action)：該方法接收一個(gè)Consumer接口函數(shù)，會(huì)將每一個(gè)流元素交給該函數(shù)進(jìn)行處理。此方法為終結(jié)方法，遍歷后不能再調(diào)用Stream流的其他方法。

Consumer<T>函數(shù)式接口是一個(gè)消費(fèi)型接口。 Consumer接口中包含抽象方法void accept(T t)，意為消費(fèi)一個(gè)指定泛型的數(shù)據(jù)。

import java.util.stream.Stream;public class Start { public static void main(String[] args) { String[] arr = {'張三', '李四', '王五'}; Stream<String> stream2 = Stream.of(arr); stream2.forEach((name)->{ System.out.println(name); }); }} Stream<T> filter(Predicate<? super T> predicate) ：將一個(gè)流轉(zhuǎn)換成另一個(gè)子集流，此方法為終結(jié)方法。

Predicate<T>函數(shù)式接口，抽象方法boolean test(T t)用來(lái)對(duì)指定數(shù)據(jù)進(jìn)行判斷是否滿(mǎn)足條件。

import java.util.stream.Stream;public class Start { public static void main(String[] args) { //獲取Stream流 String[] arr = {'張三', '李四', '王五'}; Stream<String> stream2 = Stream.of(arr); //filter方法 Stream<String> fil = stream2.filter((name) -> { return name.startsWith('張'); }); fil.forEach(name->System.out.println(name)); }} Stream<R> map(Function<? super T, ? extends R> mapper)：將流中的元素映射到另一個(gè)流中。

Function<T>函數(shù)式接口，可以將當(dāng)前流中的T類(lèi)型數(shù)據(jù)轉(zhuǎn)換為另一種R類(lèi)型的流。

import java.util.stream.Stream;public class Start { public static void main(String[] args) { //獲取Stream流 String[] arr = {'1', '2', '3'}; Stream<String> stream2 = Stream.of(arr); //map方法 Stream<Integer> map = stream2.map((string) -> { return Integer.parseInt(string); }); map.forEach(integer->System.out.println(integer)); }} long count() ：統(tǒng)計(jì)流中元素的個(gè)數(shù)，此方法為終結(jié)方法。 Stream<T> limit(long n)：用于截取流中的元素，只取用前n個(gè)元素，此方法是延遲方法，可以繼續(xù)調(diào)用Stream流中的其他方法。

stream1.limit(2).forEach(name -> System.out.println(name));

Stream<T> skip(long n)：用于跳過(guò)流中的元素，跳過(guò)n個(gè)元素，獲取剩下的元素組成新流，此方法是延遲方法。

stream1.skip(1).forEach(name -> System.out.println(name));

static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T> b)：Stream的靜態(tài)方法，將兩個(gè)流合并為一個(gè)流。

Stream.concat(stream1, stream2).forEach(string -> System.out.println(string));

以上就是詳解JAVA Stream流的詳細(xì)內(nèi)容，更多關(guān)于JAVA Stream流的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！