資訊專欄INFORMATION COLUMN
摘要：因此，使用并行流需要考慮以下幾點數據量將問題分解之后并行化處理，再將結果合并會帶來額外的開銷。
目錄
簡介
用法
例子
注意點
一. 簡介流是Java8引入的一個新特性,提供了對集合元素一系列便捷的操作，可以用很少的代碼實現復雜的功能。
流有兩大類，分別是對象流（Stream），基本數據流(IntStream、LongStream、DoubleStream)。
流的使用通常為三個步驟：①創建流 ②描述流 ③求值
創建流通過Stream靜態工廠方法來創建,Stream類提供了以下方法創建流。
of:
Stream
IntStream intStream = IntStream.of(new int[]{1, 2, 3});
generator:生成一個無限長度的Stream
可以看作是個工廠，每次返回一個給定類型的對象。
Stream
iterate:生成無限長度的Stream
其元素的生成是重復對給定的種子值（seed）調用用戶指定函數生成的
Stream
empty():生成空流
Stream.empty();
通過文件生成流:File.lines()
Stream
最常用的 通過Collection子類獲取Stream
List
Stream
通過Arrays.stream()封裝數據生成流，也很常用
IntStream intStream = Arrays.stream(new int[]{1, 2, 3});
比較少用的 CharSequence 接口方法 .chars()
String str = "hello world";
IntStream intStream = str.chars();
創建好流之后，就可以描述流了。更準確的說法是，聲明流的中間操作。
中間操作比較常用的有以下幾種(返回值為Stream的均為中間操作)
.filter(man -> man.getAge() > 18) 過濾器
.map(Man::getName) 獲取字段,map操作可以執行多次，將數據轉為我們期望的
.mapToInt 轉為數值流，這個和sum這些組合使用可以省去裝箱成本
.limit(3) 截斷流，前三個
.distinct() 去重
.sorted() 排序
.skip(3) 丟棄前三個
.flatMap(Arrays::stream) 合并流
求值與中間操作相對應的是終端操作，也就是我們的第三步，求值。
常用的終端操作有以下幾種（返回值不為Stream的為終端操作）
.collect(toList()); 結果轉為List格式
.collect(toSet()); 結構轉為Set格式，自帶distinct效果
.count(); 計數
.findfirst(); 找第一個
.findAny(); 找任何一個
.forEach(System.out::println) 為每個元素進行的操作
.min 獲取最小值
.max 獲取最大值
說明流是使用了內部迭代而不是外部迭代三.例子
內部迭代使用了惰性求值，只有在需要結果的那一刻才進行求值。
所有的中間操作（只描述流）都是惰性求值，因為只返回了Stream。
// 用戶類
public class User {
private Integer id;
private String name;
private Integer age;
// GET SET Constructor ..
}
// 初始化數據
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);
}
// 靜態導入Collectors后會更簡潔。
// import static java.util.stream.Collectors.*;
@Test
public void test2() {
// 根據年齡是否大于17歲對集合進行分塊
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() {
// 獲取年齡最大的用戶(只返回一個)
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);
}
四.注意點
如何進行調試
// 可以利用peek查看流中的數據狀態
userList.stream()
.peek(System.out::println)
.map(u -> u.getName())
.peek(System.out::println)
.collect(toList());
使用并行還是串行
