基本操作步驟
- 創(chuàng)建Stream
- 中間操作
- 終止操作
1.創(chuàng)建Stream
- Collection提供了兩個(gè)方法
- stream()
獲取一個(gè)順序流
Stream<String> stream = list.stream();
- parallelStream()
獲取一個(gè)并行流
Stream<String> parallelStream = list.parallelStream();
并行流 : 就是把一個(gè)內(nèi)容分成多個(gè)數(shù)據(jù)塊承边，并用不同的線程分 別處理每個(gè)數(shù)據(jù)塊的流
- 通過(guò)Arrays 中的 stream() 獲取一個(gè)數(shù)組流
Integer[] nums = new Integer[10];
Stream<Integer> stream1 = Arrays.stream(nums);
3.通過(guò)Stream中靜態(tài)方法of()創(chuàng)建
Stream<Integer> stream2 = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9);
- 創(chuàng)建無(wú)限流
- 迭代方式
Stream<Integer> stream3 = Stream.iterate(0, x -> x + 3);
stream3.forEach(System.out::println);
- 生成方式
Stream<Double> stream4 = Stream.generate(Math::random);
stream4.forEach(System.out::println);
2.中間操作
請(qǐng)看下一節(jié)：3. Java8 Stream 操作
3. 終止操作
1. 查找與匹配
| 方法 | 描述 |
|---|---|
| allMatch | 檢查是否匹配所有元素 |
| anyMatch | 檢查是否至少匹配一個(gè)元素 |
| noneMatch | 檢查是否沒(méi)有匹配的元素 |
| findFirst | 返回第一個(gè)元素 |
| findAny | 返回當(dāng)前流中的任意元素 |
| count | 返回流中元素的總個(gè)數(shù) |
| max | 返回流中最大值 |
| min | 返回流中最小值 |
- 例子
//篩選
//allMatch——檢查是否匹配所有元素
boolean match = emps.stream().allMatch(e -> e.getStatus().equals(Employee.Status.BUSY));
//anyMatch——檢查是否至少匹配一個(gè)元素
boolean match1 = emps.stream().anyMatch(e -> e.getStatus().equals(Employee.Status.FREE));
//noneMatch——檢查是否沒(méi)有匹配的元素
boolean match3 = emps.stream().noneMatch(e -> e.getStatus().equals(Employee.Status.BUSY));
//findFirst——返回第一個(gè)元素
Optional<Employee> first = emps.stream().findFirst();
Employee employee = first.get();
//findAny——返回當(dāng)前流中的任意元素
Optional<Employee> any = emps.stream().findAny();
Employee employee1 = any.get();
//count——返回流中元素的總個(gè)數(shù)
long count = emps.stream().count();
//max——返回流中最大值
Optional<Integer> max = emps.stream().map(Employee::getAge).max(Integer::compare);
Integer integer = max.get();
//min——返回流中最小值
emps.stream().map(Employee::getId).min(Integer::compare);
注意：流進(jìn)行了終止操作后阐污，不能再次使用
2. 歸約
| 方法 | 描述 |
|---|---|
| reduce(T iden, BinaryOperator b) | 可以將流中元素反復(fù)結(jié)合起來(lái)，得到一個(gè)值边篮。返回T |
| reduce(BinaryOperator b) | 可以將流中元素反復(fù)結(jié)合起來(lái)，得到一個(gè)值雕什。返回Optional<T> |
Optional<Integer> reduce = numList.stream().reduce((x, y) -> x + y);
int s = reduce.get();
System.out.println(s);
Optional<Integer> reduce1 = emps.stream().map(Employee::getAge).reduce(Integer::max);
System.out.println(reduce1.get());
