摘要：和不同，其沒(méi)有接收參數(shù)。用于剔除重復(fù)，與數(shù)據(jù)庫(kù)中的用法一致?？梢詫?duì)整型流求最大值，返回。這兩個(gè)方法是結(jié)束操作，只能調(diào)用一次。
常用的函數(shù)接口記錄方便以后翻吧
| 接口 |
參數(shù) |
返回類(lèi)型 |
說(shuō)明 |
| Predicate |
T |
boolean |
輸入某個(gè)值，輸出boolean 值，用于對(duì)某值進(jìn)行判定 |
| Consumer |
T |
void |
輸入某值，無(wú)輸出。用于消費(fèi)某值 |
| Function |
T |
R |
輸入某類(lèi)型值，輸出另種類(lèi)型值，用于類(lèi)型轉(zhuǎn)化等 |
| Supplier |
None |
T |
無(wú)輸入，輸出某值，用于生產(chǎn)某值 |
| UnaryOperator |
T |
T |
輸入某類(lèi)型值，輸出同類(lèi)型值，用于值的同類(lèi)型轉(zhuǎn)化，如對(duì)值進(jìn)行四則運(yùn)算等 |
| BinaryOperator |
(T,T) |
T |
輸入兩個(gè)某類(lèi)型值，輸出一個(gè)同類(lèi)型值，用于兩值合并等 |
Predicates
Predicates是包含一個(gè)參數(shù)的布爾值接口。其包括一些缺省方法，組合他們使用可以實(shí)現(xiàn)復(fù)雜的業(yè)務(wù)邏輯(如：and, or, negate)。示例代碼如下：
Predicate predicate = (s) -> s.length() > 0;
predicate.test("foo"); // true
predicate.negate().test("foo"); // false
Predicate nonNull = Objects::nonNull;
Predicate isNull = Objects::isNull;
Predicate isEmpty = String::isEmpty;
Predicate isNotEmpty = isEmpty.negate();
Functions
Functions接口接收一個(gè)參數(shù)并產(chǎn)生一個(gè)結(jié)果。其缺省方法通常被用來(lái)鏈接多個(gè)功能一起使用 (compose, andThen)。
Function toInteger = Integer::valueOf;
Function backToString = toInteger.andThen(String::valueOf);
backToString.apply("123"); // "123"
Suppliers
Suppliers接口生成一個(gè)給定類(lèi)型結(jié)果。和Functions不同，其沒(méi)有接收參數(shù)。
Supplier personSupplier = Person::new;
personSupplier.get(); // new Person
Consumers
Consumers表現(xiàn)執(zhí)行帶有單個(gè)輸入?yún)?shù)的操作。
Consumer greeter = (p) -> System.out.println("Hello, " + p.firstName);
greeter.accept(new Person("Luke", "Skywalker"));
Comparators
Comparators是從java舊版本升級(jí)并增加了一些缺省方法。
Comparator 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 常用方法
創(chuàng)建Stream
將現(xiàn)有數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)化成Stream
Stream s = Stream.of(1, 2, 3, 4, 5);
Stream s = Arrays.stream(arr);
Stream s = aList.stream();
通過(guò)Stream.generate()方法：
// 這種方法通常表示無(wú)限序列
Stream s = Stream.generate(SuppLier s);
// 創(chuàng)建全體自然數(shù)的Stream
class NatualSupplier implements Supplier {
BigInteger next = BigInteger.ZERO;
@Override
public BigInteger get() {
next = next.add(BigInteger.ONE);
return next;
}
}
通過(guò)其他方法返回
Stream lines = Files.lines(Path.get(filename))
...
map方法
把一種操作運(yùn)算映射到Stream的每一個(gè)元素上，從而完成一個(gè)Stream到另一個(gè)Stream的轉(zhuǎn)換
map方法接受的對(duì)象是Function接口，這個(gè)接口是一個(gè)函數(shù)式接口：
Stream map(Function mapper);
@FunctionalInterface
public interface Function {
// 將T轉(zhuǎn)換為R
R apply(T t);
}
使用：
// 獲取Stream里每個(gè)數(shù)的平方的集合
Stream ns = Stream.of(1, 2, 3, 4, 5);
ns.map(n -> n * n).forEach(System.out::println);
flatMap
map方法是一個(gè)一對(duì)一的映射，每輸入一個(gè)數(shù)據(jù)也只會(huì)輸出一個(gè)值。
flatMap方法是一對(duì)多的映射，對(duì)每一個(gè)元素映射出來(lái)的仍舊是一個(gè)Stream，然后會(huì)將這個(gè)子Stream的元素映射到父集合中：
Stream> inputStream = Stream.of(Arrays.asList(1), Arrays.asList(2, 3), Arrays.asList(4, 5, 6));
List integerList = inputStream.flatMap((childList) -> childList.stream()).collect(Collectors.toList());
//將一個(gè)“二維數(shù)組”flat為“一維數(shù)組”
integerList.forEach(System.out::println);
filter方法
filter方法用于過(guò)濾Stream中的元素，并用符合條件的元素生成一個(gè)新的Stream。
filter方法接受的參數(shù)是Predicate接口對(duì)象，這個(gè)接口是一個(gè)函數(shù)式接口：
Stream filter(Predicate) predicate;
@FunctionInterface
public interface Predicate {
// 判斷元素是否符合條件
boolean test(T t);
}
使用
// 獲取當(dāng)前Stream所有偶數(shù)的序列
Stream ns = Stream.of(1, 2, 3, 4, 5);
ns.filter(n -> n % 2 == 0).forEach(System.out::println);
limit、skip
limit用于限制獲取多少個(gè)結(jié)果，與數(shù)據(jù)庫(kù)中的limit作用類(lèi)似，skip用于排除前多少個(gè)結(jié)果。
sorted
sorted函數(shù)需要傳入一個(gè)實(shí)現(xiàn)Comparator函數(shù)式接口的對(duì)象，該接口的抽象方法compare接收兩個(gè)參數(shù)并返回一個(gè)整型值，作用就是排序，與其他常見(jiàn)排序方法一致。
distinct
distinct用于剔除重復(fù)，與數(shù)據(jù)庫(kù)中的distinct用法一致。
findFirst
findFirst方法總是返回第一個(gè)元素，如果沒(méi)有則返回空，它的返回值類(lèi)型是Optional類(lèi)型，接觸過(guò)swift的同學(xué)應(yīng)該知道，這是一個(gè)可選類(lèi)型，如果有第一個(gè)元素則Optional類(lèi)型中保存的有值，如果沒(méi)有第一個(gè)元素則該類(lèi)型為空。
Stream stream = users.stream();
Optional 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、max
min可以對(duì)整型流求最小值，返回OptionalInt。
max可以對(duì)整型流求最大值，返回OptionalInt。
這兩個(gè)方法是結(jié)束操作，只能調(diào)用一次。
allMatch、anyMatch、noneMatch
allMatch：Stream中全部元素符合傳入的predicate返回 true
anyMatch：Stream中只要有一個(gè)元素符合傳入的predicate返回 true
noneMatch：Stream中沒(méi)有一個(gè)元素符合傳入的predicate返回 true
reduce方法
reduce方法將一個(gè)Stream的每一個(gè)元素一次作用于BiFunction，并將結(jié)果合并。
reduce方法接受的方法是BinaryOperator接口對(duì)象。
Optional reduce(BinaryOperator accumulator);
@FuncationalInterface
public interface BinaryOperator extends BiFunction {
// Bi操作，兩個(gè)輸入，一個(gè)輸出
T apply(T t, T u);
}
使用：
// 求當(dāng)前Stream累乘的結(jié)果
Stream ns = Stream.of(1, 2, 3, 4, 5);
int r = ns.reduce( (x, y) -> x * y ).get();
System.out.println(r);
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/73566.html
