資訊專欄INFORMATION COLUMN
摘要：因此，使用并行流需要考慮以下幾點(diǎn)數(shù)據(jù)量將問題分解之后并行化處理，再將結(jié)果合并會(huì)帶來額外的開銷。
目錄
簡介
用法
例子
注意點(diǎn)
一. 簡介流是Java8引入的一個(gè)新特性,提供了對集合元素一系列便捷的操作，可以用很少的代碼實(shí)現(xiàn)復(fù)雜的功能。
流有兩大類，分別是對象流（Stream），基本數(shù)據(jù)流(IntStream、LongStream、DoubleStream)。
流的使用通常為三個(gè)步驟：①創(chuàng)建流 ②描述流 ③求值
創(chuàng)建流通過Stream靜態(tài)工廠方法來創(chuàng)建,Stream類提供了以下方法創(chuàng)建流。
of:
Stream
IntStream intStream = IntStream.of(new int[]{1, 2, 3});
generator:生成一個(gè)無限長度的Stream
可以看作是個(gè)工廠，每次返回一個(gè)給定類型的對象。
Stream
iterate:生成無限長度的Stream
其元素的生成是重復(fù)對給定的種子值（seed）調(diào)用用戶指定函數(shù)生成的
Stream
empty():生成空流
Stream.empty();
通過文件生成流:File.lines()
Stream
最常用的 通過Collection子類獲取Stream
List
Stream
通過Arrays.stream()封裝數(shù)據(jù)生成流，也很常用
IntStream intStream = Arrays.stream(new int[]{1, 2, 3});
比較少用的 CharSequence 接口方法 .chars()
String str = "hello world";
IntStream intStream = str.chars();
創(chuàng)建好流之后，就可以描述流了。更準(zhǔn)確的說法是，聲明流的中間操作。
中間操作比較常用的有以下幾種(返回值為Stream的均為中間操作)
.filter(man -> man.getAge() > 18) 過濾器
.map(Man::getName) 獲取字段,map操作可以執(zhí)行多次，將數(shù)據(jù)轉(zhuǎn)為我們期望的
.mapToInt 轉(zhuǎn)為數(shù)值流，這個(gè)和sum這些組合使用可以省去裝箱成本
.limit(3) 截?cái)嗔?，前三個(gè)
.distinct() 去重
.sorted() 排序
.skip(3) 丟棄前三個(gè)
.flatMap(Arrays::stream) 合并流
求值與中間操作相對應(yīng)的是終端操作，也就是我們的第三步，求值。
常用的終端操作有以下幾種（返回值不為Stream的為終端操作）
.collect(toList()); 結(jié)果轉(zhuǎn)為List格式
.collect(toSet()); 結(jié)構(gòu)轉(zhuǎn)為Set格式，自帶distinct效果
.count(); 計(jì)數(shù)
.findfirst(); 找第一個(gè)
.findAny(); 找任何一個(gè)
.forEach(System.out::println) 為每個(gè)元素進(jìn)行的操作
.min 獲取最小值
.max 獲取最大值
說明流是使用了內(nèi)部迭代而不是外部迭代三.例子
內(nèi)部迭代使用了惰性求值，只有在需要結(jié)果的那一刻才進(jìn)行求值。
所有的中間操作（只描述流）都是惰性求值，因?yàn)橹环祷亓薙tream。
// 用戶類
public class User {
private Integer id;
private String name;
private Integer age;
// GET SET Constructor ..
}
// 初始化數(shù)據(jù)
ListuserList = new ArrayList () { /** */ private static final long serialVersionUID = 1L; { add(new User(1, "Luffy", 17)); ? add(new User(2, "Zoro", 19)); add(new User(3, "Nami", 18)); add(new User(4, "Usopp", 17)); add(new User(5, "Sanji", 19)); add(new User(6, "Chopper", 15)); add(new User(7, "Robin", 28)); add(new User(8, "FRANKY", 34)); add(new User(9, "BROOK", 88)); } };
// 例子
@Test
public void test1() {
// 獲取所有年齡大于17的用戶
List users = userList.stream()
.filter(user -> user.getAge() > 17)
.collect(Collectors.toList());
System.out.println(users);
}
// 靜態(tài)導(dǎo)入Collectors后會(huì)更簡潔。
// import static java.util.stream.Collectors.*;
@Test
public void test2() {
// 根據(jù)年齡是否大于17歲對集合進(jìn)行分塊
Map> users = userList.stream()
.collect(partitioningBy(u -> u.getAge() > 17));
System.out.println(users);
}
@Test
public void test3() {
// 按照年齡，將用戶分組
Map> users = userList.stream()
.collect(groupingBy(User::getAge));
System.out.println(users);
}
@Test
public void test4() {
// 獲取所有用戶的名稱
List names = userList.stream()
.map(User::getName)
.collect(toList());
System.out.println(names);
}
@Test
public void test5() {
// 獲取年齡最大的用戶(只返回一個(gè))
User user = userList.stream()
.max((u1, u2) -> {
return u1.getAge() > u2.getAge() ? 1 : -1;
})
.get();
System.out.println(user);
}
@Test
public void test6() {
// 獲取用戶年齡總和
int ageSum = userList.stream()
.map(User::getAge)
.reduce(0, (acc, element) -> {
acc += element;
return acc;
});
System.out.println(ageSum);
ageSum = userList.stream()
.map(User::getAge)
.reduce(0, Integer::sum);
System.out.println(ageSum);
ageSum = userList.stream()
.collect(summingInt(User::getAge));
System.out.println(ageSum);
}
@Test
public void test7() {
// 獲取組成用戶姓名的字母
Set set = userList.stream()
.map(User::getName)
.map(name -> name.split(""))
.flatMap(Arrays::stream)
.collect(toSet());
System.out.println(set);
}
四.注意點(diǎn)
如何進(jìn)行調(diào)試
// 可以利用peek查看流中的數(shù)據(jù)狀態(tài)
userList.stream()
.peek(System.out::println)
.map(u -> u.getName())
.peek(System.out::println)
.collect(toList());
使用并行還是串行
