Java 8 的 Stream API是對集合(Collection)功能的增強,能進行各種便利、高效的聚合操作(aggregate operation),或者數據操作。
同時提供順序流和並行流兩模式進行匯聚操作:
- 並行模式:把一個內容分成多個數據塊,並用不同的線程分別處理每個數據塊的流(Fork/Join),能夠充分利用多核處理器的優勢。使用 fork/join 並行方式拆分任務和加速處理過程。
- 順序模式:一個一個執行
- 順序流的操作是在單線程上執行,而並行流的操作是在多線程上併發。
- 並不是所有的問題都適合使用並行模式,考量要點:數據量、任務是否獨立、資料是否有順序
- stream() − 為集合創建串行流;parallelStream() − 為集合創建並行流。
Stream建構方法
//基本數值型,目前有三種對應的包裝類型 Stream:IntStream、LongStream、DoubleStream ,可以直接套用增加效能
//Individual values
Stream stream = Stream.of("a", "b", "c");
// 2. Arrays
String [] strArray = new String[] {"a", "b", "c"};
Stream streamA = Stream.of(strArray);
Stream streamB = Arrays.stream(strArray);
IntStream.of(new int[]{1, 2, 3});
IntStream.range(1, 3);
IntStream.rangeClosed(1, 3);
// 3. Collections
List<String> list = Arrays.asList(strArray);
Stream stream = list.stream();
Stream API操作類型
- intermediate operation( 中介操作 ):map (mapToInt, flatMap 等)、 filter、 distinct、 sorted、 peek、 limit、 skip、 parallel、 sequential、 unordered。
一個Stream後面可以跟隨0或多個操作,尚未真正開始Stream的遍歷,多個操作在 Terminal 操作的時候一次循環完成
- terminal operations( 聚合操作 ):forEach、 forEachOrdered、 toArray、 reduce、 collect、 min、 max、 count、 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 iterator,真正開始Stream的遍歷
- Short-circuiting: anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 limit
filter:過濾,符合條件的留下
List<String> strList = Arrays.asList("A", "B", "AA", "C");
List<String> strListAfter = strList.stream()
.filter(x -> x.contains("A"))
.collect(Collectors.toList());
map:把 input Stream 的每一個元素,映射成 output Stream 的另外一個元素