接口 | 參數 | 返回類型 | 說明 |
---|---|---|---|
Predicate<T> | T | boolean | 輸入某個值,輸出boolean 值,用於對某值進行斷定 |
Consumer<T> | T | void | 輸入某值,無輸出。用於消費某值 |
Function<T,R> | T | R | 輸入某類型值,輸出另種類型值,用於類型轉化等 |
Supplier<T> | None | T | 無輸入,輸出某值,用於生產某值 |
UnaryOperator<T> | T | T | 輸入某類型值,輸出同類型值,用於值的同類型轉化,如對值進行四則運算等 |
BinaryOperator<T> | (T,T) | T | 輸入兩個某類型值,輸出一個同類型值,用於兩值合併等 |
Predicates是包含一個參數的布爾值接口。其包括一些缺省方法,組合他們使用能夠實現複雜的業務邏輯(如:and, or, negate)。示例代碼以下:java
Predicate<String> predicate = (s) -> s.length() > 0; predicate.test("foo"); // true predicate.negate().test("foo"); // false Predicate<Boolean> nonNull = Objects::nonNull; Predicate<Boolean> isNull = Objects::isNull; Predicate<String> isEmpty = String::isEmpty; Predicate<String> isNotEmpty = isEmpty.negate();
Functions接口接收一個參數併產生一個結果。其缺省方法一般被用來連接多個功能一塊兒使用 (compose, andThen)。數據庫
Function<String, Integer> toInteger = Integer::valueOf; Function<String, String> backToString = toInteger.andThen(String::valueOf); backToString.apply("123"); // "123"
Suppliers接口生成一個給定類型結果。和Functions不一樣,其沒有接收參數。swift
Supplier<Person> personSupplier = Person::new; personSupplier.get(); // new Person
Consumers表現執行帶有單個輸入參數的操做。數組
Consumer<Person> greeter = (p) -> System.out.println("Hello, " + p.firstName); greeter.accept(new Person("Luke", "Skywalker"));
Comparators是從java舊版本升級並增長了一些缺省方法。數據結構
Comparator<Person> comparator = (p1, p2) -> p1.firstName.compareTo(p2.firstName); Person p1 = new Person("John", "Doe"); Person p2 = new Person("Alice", "Wonderland"); comparator.compare(p1, p2); // > 0 comparator.reversed().compare(p1, p2); // < 0
Stream<Integer> s = Stream.of(1, 2, 3, 4, 5); Stream<Integer> s = Arrays.stream(arr); Stream<Integer> s = aList.stream();
// 這種方法一般表示無限序列 Stream<T> s = Stream.generate(SuppLier<T> s); // 建立全體天然數的Stream class NatualSupplier implements Supplier<BigInteger> { BigInteger next = BigInteger.ZERO; @Override public BigInteger get() { next = next.add(BigInteger.ONE); return next; } }
Stream<String> lines = Files.lines(Path.get(filename)) ...
把一種操做運算映射到Stream的每個元素上,從而完成一個Stream到另外一個Stream的轉換
map方法接受的對象是Function接口,這個接口是一個函數式接口:app
<R> Stream<R> map(Function<? super T, ? extends R> mapper); @FunctionalInterface public interface Function<T, R> { // 將T轉換爲R R apply(T t); }
使用:ide
// 獲取Stream裏每一個數的平方的集合 Stream<Integer> ns = Stream.of(1, 2, 3, 4, 5); ns.map(n -> n * n).forEach(System.out::println);
map方法是一個一對一的映射,每輸入一個數據也只會輸出一個值。 函數
flatMap方法是一對多的映射,對每個元素映射出來的仍舊是一個Stream,而後會將這個子Stream的元素映射到父集合中:ui
Stream<List<Integer>> inputStream = Stream.of(Arrays.asList(1), Arrays.asList(2, 3), Arrays.asList(4, 5, 6)); List<Integer> integerList = inputStream.flatMap((childList) -> childList.stream()).collect(Collectors.toList()); //將一個「二維數組」flat爲「一維數組」 integerList.forEach(System.out::println);
filter方法用於過濾Stream中的元素,並用符合條件的元素生成一個新的Stream。
filter方法接受的參數是Predicate接口對象,這個接口是一個函數式接口:code
Stream<T> filter(Predicate<? super T>) predicate; @FunctionInterface public interface Predicate<T> { // 判斷元素是否符合條件 boolean test(T t); }
使用
// 獲取當前Stream全部偶數的序列 Stream<Integer> ns = Stream.of(1, 2, 3, 4, 5); ns.filter(n -> n % 2 == 0).forEach(System.out::println);
limit用於限制獲取多少個結果,與數據庫中的limit做用相似,skip用於排除前多少個結果。
sorted函數須要傳入一個實現Comparator函數式接口的對象,該接口的抽象方法compare接收兩個參數並返回一個整型值,做用就是排序,與其餘常見排序方法一致。
distinct用於剔除重複,與數據庫中的distinct用法一致。
findFirst方法老是返回第一個元素,若是沒有則返回空,它的返回值類型是Optional<T>類型,接觸過swift的同窗應該知道,這是一個可選類型,若是有第一個元素則Optional類型中保存的有值,若是沒有第一個元素則該類型爲空。
Stream<User> stream = users.stream(); Optional<String> userID = stream.filter(User::isVip).sorted((t1, t2) -> t2.getBalance() - t1.getBalance()).limit(3).map(User::getUserID).findFirst(); userID.ifPresent(uid -> System.out.println("Exists"));
min能夠對整型流求最小值,返回OptionalInt。
max能夠對整型流求最大值,返回OptionalInt。
這兩個方法是結束操做,只能調用一次。
allMatch:Stream中所有元素符合傳入的predicate返回 true
anyMatch:Stream中只要有一個元素符合傳入的predicate返回 true
noneMatch:Stream中沒有一個元素符合傳入的predicate返回 true
reduce方法將一個Stream的每個元素一次做用於BiFunction,並將結果合併。
reduce方法接受的方法是BinaryOperator接口對象。
Optional<T> reduce(BinaryOperator<T> accumulator); @FuncationalInterface public interface BinaryOperator<T> extends BiFunction<T, T, T> { // Bi操做,兩個輸入,一個輸出 T apply(T t, T u); }
使用:
// 求當前Stream累乘的結果 Stream<Integer> ns = Stream.of(1, 2, 3, 4, 5); int r = ns.reduce( (x, y) -> x * y ).get(); System.out.println(r);