視頻地址https://www.bilibili.com/video/BV1Cv411372m?
1 Stream流概述
-
目的：簡化集合和陣列操作的API，結合了Lambda運算式，
-
Stream流式思想的核心：
- 先得到集合或者陣列的Stream流(就是一根傳送帶)
- 把元素放上去
- 用這個Stream流簡化的API來方便的操作元素
2 Stream流獲取
- Stream流的三類方法：
- 獲取Stream流
- 創建一條流水線，并把資料放到流水線上準備進行操作，
- 中間方法
- 流水線上的操作，一次操作完畢之后，還可以繼續進行其他操作，
- 終結方法
- 一個Stream流只能有一個終結方法，是流水線上的最后一個操作，
- Stream操作集合或者陣列的第一步是先得到Stream流，然后才能使用流的功能，
- 集合獲取Stream流的方式
使用Collection介面中的默認方法stream()生成流
/***Collection集合獲取流********/
Collection<String> list = new ArrayList<>();
Stream<String> s = list.stream();
/*** Map集合獲取流*/
Map<String,Integer> maps = new HashMap<>();
//鍵流
Stream<String> keyStream = maps.keySet().stream();
// 值流
Stream<Integer> valueStream = maps.values().stream();
//鍵值對流(拿整體)
Stream<Map.Entry<String, Integer>> keyAndValueStream = maps.entrySet().stream();
- 陣列獲取Stream流的方式
/**陣列獲取流****/
String[] names = {"張三","李四","王五","范二"};
Stream<String> nameStream = Arrays.stream(names);
Stream<String> nameStream2 = Stream.of(names);
3 Stream流的常用API
3-1 中間操作方法
注意：
- 中間方法也稱為非終結方法，呼叫完成后回傳的新的Stream流可以繼續使用，支持鏈式編程，
- 在Stream流中無法直接修改集合、陣列中的資料，
示例
- 過濾:查找出以"張"開頭的人的名字
list.stream().filter(s->s.startsWith("張")).forEach(s-> System.out.println(s));
- 統計字串長度為3的蒜素個數
long size = list.stream().filter(s -> s.length() == 3).count();
- limit獲取前幾個元素
forEach(s -> System.out.println(s)
當s和sout內的s是相同元素時，可以簡寫成System.out::println
filter代表開始過濾，->代表開始過濾，
list.stream().filter(s -> s.startsWith("張")).limit(2).forEach(s -> System.out.println(s));
list.stream().filter(s -> s.startsWith("張")).limit(2).forEach(System.out::println);
- skip跳過前幾個元素
list.stream().filter(s -> s.startsWith("張")).skip(2).forEach(System.out::println);
- Map:加工方法 :第一個方法為原材料,第二個引數是加工后的結果
- 給集合元素前面都加上一個前綴xxx
list.stream().map(s -> "xxxx"+s).forEach(System.out::println);
- 把所有名字都加工成一個學生物件
2為1的簡寫
1、list.stream().map(s -> new Student(s)).forEach(System.out::println);
2、list.stream().map(Student::new).forEach(System.out::println);
- 合并流
//public static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T> b)
//兩個不同流合并，例如流1是String型別，流2是Integer型別，此時合并后的流需要是流1和流2的父類,即父類可以接收子類
Stream<String> s1 = list.stream().filter(s -> s.startsWith("張"));
Stream<String> s2 = Stream.of("Java1","Java2");
Stream<String> s3 = Stream.concat(s1,s2);
s3.distinct().forEach(System.out::println);
3-2 終結操作方法
注意：終結操作方法，呼叫完成后流就無法繼續使用了，原因是不會回傳Stream了，
4 Stream流的綜合應用
- 新建一個類存盤員工資訊
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Employee {
private String name;
private char sex;
private double salary;
private double bonus;
private String punish; //處罰資訊
}
- 定義兩個集合，并向集合中添加元素
List<Employee> one = new ArrayList<>();
one.add(new Employee("豬八戒",'男',30000,25000,null));
one.add(new Employee("孫悟空",'男',25000,1000,"遲到"));
one.add(new Employee("沙僧",'男',2000,20000,null));
one.add(new Employee("小白龍",'男',20000,25000,null));
List<Employee> two = new ArrayList<>();
two.add(new Employee("武松",'男',15000,9000,null));
two.add(new Employee("李逵",'男',25000,10000,null));
two.add(new Employee("西門慶",'男',50000,10000,"遲到"));
two.add(new Employee("潘金蓮",'女',3500,1000,"打人"));
two.add(new Employee("武大郎",'女',20000,0,"偷竊"));
- 篩選兩個部門的最高工資的員工資訊，
新建一個物件Topperformer
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Topperformer {
private String name;
private double money;//月薪
}
// 1、開發1部的最高工資的員工
//指定大小規則
Topperformer t = one.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.map(e -> new Topperformer(e.getName(), e.getSalary() + e.getBonus())).get();
// 2、開發2部的最高工資資訊
// 1)先用max定義規則,比較大小;2)用map進行加工
Topperformer t2 = two.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.map(e -> new Topperformer(e.getName(), e.getSalary() + e.getBonus())).get();
- 統計2個部門的平均月收入，去掉最高工資和最低工資，
//開發1部
one.stream().sorted((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus())).
skip(1).limit(one.size()-2).forEach(e->{
//求出總和：剩余員工的工資總和
allMoney += e.getBonus()+e.getSalary();
});
System.out.println("開發1部的平均工資是" +allMoney/(one.size()-2));
//開發2部
two.stream().sorted((e1,e2)->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus()))
.skip(1).limit(two.size()-2).forEach(employee -> {
allMoney2 += employee.getSalary()+employee.getBonus();
});
System.out.println("開發2的平均月收入是"+allMoney2);
- 統計兩個部門的整體平均工資
Stream<Employee> s1 = one.stream();
Stream<Employee> s2 = two.stream();
Stream<Employee> s3 = Stream.concat(s1, s2);
s3.sorted((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.skip(1).limit(one.size()+two.size()-2).forEach(e ->{
allMoney3 += e.getSalary()+e.getBonus();
});
BigDecimal a = BigDecimal.valueOf(allMoney3);
BigDecimal b = BigDecimal.valueOf(one.size()+ two.size()-2);
System.out.println("2個部門的整體平均工資是" +a.divide(b,2, RoundingMode.HALF_UP));
整體代碼：
package stream_test;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Stream;
public class StreamDemo1 {
public static double allMoney;
public static double allMoney2;
public static double allMoney3;
public static void main(String[] args) {
List<Employee> one = new ArrayList<>();
one.add(new Employee("豬八戒",'男',30000,25000,null));
one.add(new Employee("孫悟空",'男',25000,1000,"遲到"));
one.add(new Employee("沙僧",'男',2000,20000,null));
one.add(new Employee("小白龍",'男',20000,25000,null));
List<Employee> two = new ArrayList<>();
two.add(new Employee("武松",'男',15000,9000,null));
two.add(new Employee("李逵",'男',25000,10000,null));
two.add(new Employee("西門慶",'男',50000,10000,"遲到"));
two.add(new Employee("潘金蓮",'女',3500,1000,"打人"));
two.add(new Employee("武大郎",'女',20000,0,"偷竊"));
// 1、開發1部的最高工資的員工
//指定大小規則
// Employee employee = one.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
// .get();
Topperformer t = one.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.map(e -> new Topperformer(e.getName(), e.getSalary() + e.getBonus())).get();
System.out.println(t);
// 3-2、開發2部的最高工資資訊
// 1)先用max定義規則,比較大小;2)用map進行加工
Topperformer topperformer = two.stream().max((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.map(e -> new Topperformer(e.getName(), e.getSalary() + e.getBonus())).get();
System.out.println(topperformer);
// 不能在main方法中定義一個區域變數供main方法中的foreach回圈使用，
// 因為main方法和foreach屬于不同的方法堆疊，在不同的堆疊里面跑，互相不能訪問，
// 解決辦法：共享變數：所有變數都可以訪問，屬于類
// 2、統計平均工資，去掉最高工資和最低工資 e1在前就是升序，e2在前就是降序
one.stream().sorted((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus())).
skip(1).limit(one.size()-2).forEach(e->{
//求出總和：剩余員工的工資總和
allMoney += e.getBonus()+e.getSalary();
});
System.out.println("開發1部的平均工資是" +allMoney/(one.size()-2));
// 4-2、開發2部的平均月收入，去掉最高和最低工資，
two.stream().sorted((e1,e2)->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus()))
.skip(1).limit(two.size()-2).forEach(employee -> {
allMoney2 += employee.getSalary()+employee.getBonus();
});
System.out.println("開發2的平均月收入是"+allMoney2);
// 3、合并2個集合流
Stream<Employee> s1 = one.stream();
Stream<Employee> s2 = two.stream();
Stream<Employee> s3 = Stream.concat(s1, s2);
s3.sorted((e1, e2) -> Double.compare(e1.getSalary() + e1.getBonus(), e2.getSalary() + e2.getBonus()))
.skip(1).limit(one.size()+two.size()-2).forEach(e ->{
allMoney3 += e.getSalary()+e.getBonus();
});
BigDecimal a = BigDecimal.valueOf(allMoney3);
BigDecimal b = BigDecimal.valueOf(one.size()+ two.size()-2);
System.out.println("2個部門的整體平均工資是" +a.divide(b,2, RoundingMode.HALF_UP));
}
}
5 Stream流的收集操作
- 收集Stream流的含義：把Stream流操作后的結果資料轉回到集合或者陣列中去，流只能使用一次，
- Stream流：方便操作集合/陣列的手段，
- 集合/陣列：才是開發中的目的，
- 轉換成list集合
Stream<String> s1 = list.stream().filter(s ->
s.startsWith("張")
);
//List<String> list1 = s1.toList(); //得到不可變集合
List<String> zhangList = s1.collect(Collectors.toList());
- 轉換成set集合
Stream<String> s2 = list.stream().filter(s ->
s.startsWith("張")
);
Set<String> zhangList2 = s2.collect(Collectors.toSet());
- 轉換成陣列
Stream<String> s3 = list.stream().filter(s -> s.startsWith("張"));
// Stream<String>轉換成陣列時，默認轉換成Object形式
// Object[] arrs = s3.toArray();
// 如果非要把object型別轉為String型別
String[] arrs = s3.toArray(s->new String[s]);
// String[] arrs2 = s3.toArray(String[]::new);
System.out.println(arrs); //輸出陣列的地址
System.out.println(Arrays.toString(arrs)); //輸出陣列的值
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/553074.html
標籤：其他
上一篇：python呼叫父類方法的三種方式（super呼叫和父類名呼叫）
下一篇：返回列表