
lambda表達式簡明扼要的以流水線的方式去處理集合內(nèi)的數(shù)據(jù),可以很輕松的完成過濾、分組、收集、歸約這類操作。
總得來說,lambda的操作分為兩類:中間型和最終型。

中間型操作
1、filter
filter會按照指定的條件匹配出符合要求的元素,并返回一個新的stream流,可以配合其他中間型或最終型API使用。
示例:
List<String> dataList = Lists.newArrayList("first", "second", "third");
List<String> filter = dataList.stream()
.filter(
//篩選出值為second的匹配項
data -> data.equals("second")
)
.collect(Collectors.toList());
System.out.println(filter);// [second]
2、map
map可以將一個對象轉(zhuǎn)換為另一個對象,并返回一個新的stream流,比如將一個Integer對象轉(zhuǎn)換為String對象。
示例:
List<Integer> dataList = Lists.newArrayList(1, 2, 3);
List<String> transform = dataList.stream()
.map(
//也可以寫成String::valueOf
data -> String.valueOf(data)
)
.collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));// ["1","2","3"]
3、peek
peek會對流中的元素逐個遍歷處理,它與map的區(qū)別在于:map一般用于對象的轉(zhuǎn)換,peek用于對象的消費,即不改變元素本身的類型。
List<String> dataList = Lists.newArrayList("a", "b", "c");
List<String> transform = dataList.stream()
//peek是對元素逐一消費,在這里程序會逐個打印a、b、c
.peek(data -> System.out.println(data))
//map是對元素進行轉(zhuǎn)換,這里將其轉(zhuǎn)成大寫:["A","B","C"]
.map(data -> data.toUpperCase())
.collect(Collectors.toList());
4、flatMap
flatMap可以將已有的對象轉(zhuǎn)換為另一個對象,它是一個一對多的邏輯。它與map的區(qū)別在于:map是一對一的,即將一個對象轉(zhuǎn)換為另一個對象,而flatMap是一對多的,即將一個對象拆分對多個對象。
//將["hello", "world"]轉(zhuǎn)換為["h","e","l","l","o","w","o","r","l","d"]
List<String> dataList = Lists.newArrayList("hello", "world");
List<String> transform = dataList.stream()
.flatMap(
data -> Arrays.stream(data.split(""))
)
.collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
5、limit
就相當于sql中的limit,可以指定保留前N的元素。
List<String> dataList = Lists.newArrayList("hello", "world", "good", "boy");
List<String> transform = dataList.stream()
.limit(2)
.collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
//["hello","world"]
6、skip
作用與limit相反,會拋棄前N的元素。
List<String> dataList = Lists.newArrayList("hello", "world", "good", "boy");
List<String> transform = dataList.stream()
.skip(2)
.collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
//["good","boy"]
7、concat
可以將多個流的數(shù)據(jù)合并為一個流。
List<String> transform = Stream.concat(
Stream.of("hello"),
Stream.of("world")
).collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
//["hello","world"]
8、distinct
用于對流中的元素去重。
ArrayList<String> dataList = Lists.newArrayList("1", "2", "2", "3", "3");
List<String> transform = dataList.stream().distinct().collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
//["1","2","3"]
9、sorted
用于對流中的數(shù)據(jù)排序。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
List<String> transform = dataList.stream()
.sorted(
Comparator.comparingInt(Integer::parseInt)
)
.collect(Collectors.toList());
System.out.println(JSON.toJSONString(transform));
//["1","2","3","3","4"]

最終型操作
10、count
統(tǒng)計元素的個數(shù),不會自動去重。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
long count = dataList.stream().count();
System.out.println(count);
//5
11、max
匹配元素最大值并返回。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
String max = dataList.stream().max(
Comparator.comparing(Integer::parseInt)
).get();
System.out.println(max);
//4
12、min
匹配元素最小值并返回。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
String min = dataList.stream().min(
Comparator.comparing(Integer::parseInt)
).get();
System.out.println(min);
//1
13、findFirst
找到第一個匹配的元素后立即返回。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
String first = dataList.stream().findFirst().get();
System.out.println(first);
//1
14、findAny
找到任何匹配的元素就返回。如果用在一個串行流中,跟findFirst效果一樣。如果用在并行流中,就會比較高效。
int asInt = IntStream.range(1, 10).parallel().findAny().getAsInt();
System.out.println(asInt);
//6
15、anyMatch
用于判斷是否有符合匹配條件的元素。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
boolean match = dataList.stream().anyMatch(
data -> data.equals("3")
);
System.out.println(match);
//true
16、allMatch
用于判斷是否所有元素都符合匹配條件。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
boolean match = dataList.stream().allMatch(
data -> data.equals("3")
);
System.out.println(match);
//false
17、noneMatch
用于判斷是否所有元素都不符合匹配條件。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
boolean match = dataList.stream().noneMatch(
data -> data.equals("3")
);
System.out.println(match);
//false
18、collect
將流轉(zhuǎn)換為指定的類型,比如List轉(zhuǎn)換為Set。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
Set<String> collect = dataList.stream().collect(Collectors.toSet());
System.out.println(collect);
//[1, 2, 3, 4]
19、reduce
將元素合并起來,得到一個新值。
int reduce = IntStream.range(0, 10).reduce(0, (v1, v2) -> v1 + v2);
System.out.println(reduce);//45
20、toArray
將流轉(zhuǎn)換為數(shù)組。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
Object[] collect = dataList.stream().toArray();
System.out.println(JSON.toJSONString(collect));
//["1","3","4","2","3"]
21、iterator
將流轉(zhuǎn)換為一個迭代器。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
Iterator<String> iterator = dataList.stream().iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
22、foreach
對流中的元素逐個遍歷。
ArrayList<String> dataList = Lists.newArrayList("1", "3", "4", "2", "3");
dataList.stream().forEach(
data -> System.out.println(data)
);
//等同于
dataList.forEach(data-> System.out.println(data));