流相關的接口和類在java.util.stream包中。
AutoCloseable接口來自java.lang包。
所有流接口從繼承自AutoCloseable接口的BaseStream接口繼承。
AutoCloseable
|
+--BaseStream
|
+--IntStream
|
+--LongStream
|
+--DoubleStream
|
+--Stream
如果流使用集合作為其數據源，并且集合不需要關閉。
如果流基于可關閉的數據源(例如文件I/O通道)，那么我們可以使用try-with-resources語句創建流，以使其自動關閉。
BaseStream
BaseStream接口定義所有類型的流的所有方法。
- Iterator iterator()
- 終端操作
- 返回流的迭代器。
- sequential()
- 中間操作
- 返回順序流。 如果流已經是順序的，則它返回自身。 它將并行流轉換為順序流。
- parallel()
- 中間操作
- 返回并行流。 如果流已經是并行的，則它返回自身。 它將并行流轉換為順序流。
- boolean isParallel()
- 如果流是并行，則返回true，否則返回false。
- 在調用終端流操作方法后調用此方法可能會產生不可預測的結果。
- unordered()
- 中間操作
- 返回流的無序版本。 如果流已經是無序的，則它返回自身。
流
Stream 接口表示元素類型T的流。
流 表示學生對象流。
Stream 接口包含諸如filter()，map()，reduce()，collect()，max()，min()等。
當使用原始類型時，我們可以使用三個專門的流接口，稱為IntStream，LongStream和DoubleStream。
這些接口提供了處理原始值的方法。
對于其他基本類型，例如float，short，byte，我們仍然可以使用三個專用流接口。
在下面的代碼中，我們將使用stream來計算列表中所有奇整數的平方和。
我們將使用以下步驟進行計算。
創建流
Collection接口中的stream()方法返回一個順序流。 這樣，集合充當數據源。
下面的代碼創建一個List 并從列表中獲取一個Stream
List numbersList = Arrays.asList(1, 2, 3, 4, 5);Stream numbersStream = numbersList.stream();過濾流
如果指定的謂詞對于該元素返回真，Stream filter()使用Predicate來保留元素。
以下語句獲取僅奇數整數的流：
Stream< Integer> oddNumbersStream = numbersStream.filter(n - > n％2 == 1);
映射流
Stream< T> map()使用一個Function來映射每個元素在流中創建新流。
以下語句將流映射到其正方形:
Stream aStream = stream.map(n -> n * n);Reduce流
reduce(T identity，BinaryOperator累加器)將流減少到單個值。
它采用一個初始值和一個 BinaryOperator 作為參數的累加器。
reduce(T identity，BinaryOperator< T>累加器)使用所提供的初始值和關聯累積函數對該流的元素執行減少，并返回減小的值。
這相當于:
T result = identity;for (T element : this stream) result = accumulator.apply(result, element)return result;以下代碼將流中的所有整數相加。
int sum = aStream.reduce(0, (n1, n2) -> n1 + n2);
Integer.sum()方法執行兩個整數的和。
我們可以使用方法引用重寫代碼。
int sum = aStream.reduce(0, Integer::sum);
Together
以下代碼將每個步驟鏈接在一起。
import java.util.Arrays;import java.util.List;public class Main { public static void main(String[] args) { List numbers = Arrays.asList(1, 2, 3, 4, 5); int sum = numbers.stream() .filter(n -> n % 2 == 1) .map(n -> n * n) .reduce(0, Integer::sum); System.out.println(sum); }}上面的代碼生成以下結果。
有序流與無序流
流可以是有序的或無序的。
有序流保持其元素的順序。
Streams API可以將有序流(其可以表示有序數據源，例如列表或有序集)轉換成無序流。
我們還可以通過應用排序中間操作將無序流轉換為有序流。
import java.util.Arrays;import java.util.List;public class Main { public static void main(String[] args) { List numbers = Arrays.asList(3,7,9,3,1,2,1, 2, 3, 4, 5); numbers.stream() .filter(n -> n % 2 == 1) .sorted() .forEach(System.out::println); }}
)
)
