Skip to content

Commit b5aac3e

Browse files
brianwaybrianway
committed
[add] add usage examples of Stream API.
1 parent 519ba7a commit b5aac3e

File tree

11 files changed

+170
-6
lines changed

11 files changed

+170
-6
lines changed

‎java-jvm/src/main/java/com/brianway/learning/java/jvm/dynamictype/GrandFatherCaller.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,9 @@
99
* Created by brian on 17/3/20.
1010
* 使用 MethodHandle 来访问祖类方法
1111
* TODO 为什么打印出来的是 "i am father" 而不是 "i am grandfather"?
12+
* 参考:
13+
* https://www.zhihu.com/question/57379777
14+
* https://www.zhihu.com/question/40427344/answer/86545388
1215
*/
1316
public class GrandFatherCaller {
1417
class GrandFather {

‎java8/README.md

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,12 @@
1111

1212
## steam API
1313

14-
- Dish:
14+
- Dish: 菜肴类,有一个静态属性的菜肴列表
1515
- StreamBasic: 指令式和函数式分别挑选低热量食物名
16-
- StreamOperation: 流操作:中间操作和终端操作
16+
- StreamOperation: 流操作(中间操作和终端操作)
17+
18+
使用流
19+
20+
- Filtering: 筛选(谓词筛选：filter;筛选互异的元素：distinct;忽略头几个元素：limit;截短至指定长度：skip)
21+
- Mapping: 映射
22+
- PuttingIntoPractice: 各种流操作的使用示例

‎java8/src/main/java/com/brianway/learning/java8/streamapi/StreamBasic.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,9 @@ public static void main(String... args) {
2424

2525
}
2626

27+
/**
28+
* 指令式
29+
*/
2730
public static List<String> getLowCaloricDishesNamesInJava7(List<Dish> dishes) {
2831
List<Dish> lowCaloricDishes = new ArrayList<>();
2932
for (Dish d : dishes) {
@@ -43,6 +46,9 @@ public int compare(Dish d1, Dish d2) {
4346
return lowCaloricDishesName;
4447
}
4548

49+
/**
50+
* 函数式
51+
*/
4652
public static List<String> getLowCaloricDishesNamesInJava8(List<Dish> dishes) {
4753
return dishes.stream()
4854
.filter(d -> d.getCalories() < 400)

‎java8/src/main/java/com/brianway/learning/java8/streamapi/StreamOperation.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,5 +26,9 @@ public static void main(String[] args) {
2626
.limit(3)
2727
.collect(Collectors.toList());
2828
System.out.println(names);
29+
30+
//forEach 是一个返回 void 的终端操作
31+
System.out.println("------forEach-------");
32+
menu.stream().forEach(System.out::println);
2933
}
3034
}

‎java8/src/main/java/com/brianway/learning/java8/streamapi/PuttingIntoPractice.java renamed to ‎java8/src/main/java/com/brianway/learning/java8/streamapi/practice/PuttingIntoPractice.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,14 @@
1-
package com.brianway.learning.java8.streamapi;
1+
package com.brianway.learning.java8.streamapi.practice;
22

33
import static java.util.Comparator.comparing;
44
import static java.util.stream.Collectors.toList;
55

66
import java.util.Arrays;
77
import java.util.List;
88

9+
/**
10+
* 各种流操作的使用示例
11+
*/
912
public class PuttingIntoPractice {
1013
public static void main(String... args) {
1114
Trader raoul = new Trader("Raoul", "Cambridge");

‎java8/src/main/java/com/brianway/learning/java8/streamapi/Trader.java renamed to ‎java8/src/main/java/com/brianway/learning/java8/streamapi/practice/Trader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.brianway.learning.java8.streamapi;
1+
package com.brianway.learning.java8.streamapi.practice;
22

33
public class Trader {
44

‎java8/src/main/java/com/brianway/learning/java8/streamapi/Transaction.java renamed to ‎java8/src/main/java/com/brianway/learning/java8/streamapi/practice/Transaction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.brianway.learning.java8.streamapi;
1+
package com.brianway.learning.java8.streamapi.practice;
22

33
public class Transaction {
44

‎java8/src/main/java/com/brianway/learning/java8/streamapi/usage/Filtering.java

Lines changed: 54 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
package com.brianway.learning.java8.streamapi.usage;
2+
3+
import com.brianway.learning.java8.streamapi.Dish;
4+
import static com.brianway.learning.java8.streamapi.Dish.menu;
5+
import static java.util.stream.Collectors.toList;
6+
7+
import java.util.Arrays;
8+
import java.util.List;
9+
10+
/**
11+
*筛选
12+
* - 谓词筛选：filter
13+
* - 筛选互异的元素：distinct
14+
* - 忽略头几个元素：limit
15+
* - 截短至指定长度：skip
16+
*/
17+
public class Filtering {
18+
19+
public static void main(String...args){
20+
21+
// Filtering with predicate
22+
List<Dish> vegetarianMenu =
23+
menu.stream()
24+
.filter(Dish::isVegetarian)
25+
.collect(toList());
26+
27+
vegetarianMenu.forEach(System.out::println);
28+
29+
// Filtering unique elements
30+
List<Integer> numbers = Arrays.asList(1, 2, 1, 3, 3, 2, 4);
31+
numbers.stream()
32+
.filter(i -> i % 2 == 0)
33+
.distinct()
34+
.forEach(System.out::println);
35+
36+
// Truncating a stream
37+
List<Dish> dishesLimit3 =
38+
menu.stream()
39+
.filter(d -> d.getCalories() > 300)
40+
.limit(3)
41+
.collect(toList());
42+
43+
dishesLimit3.forEach(System.out::println);
44+
45+
// Skipping elements
46+
List<Dish> dishesSkip2 =
47+
menu.stream()
48+
.filter(d -> d.getCalories() > 300)
49+
.skip(2)
50+
.collect(toList());
51+
52+
dishesSkip2.forEach(System.out::println);
53+
}
54+
}

‎java8/src/main/java/com/brianway/learning/java8/streamapi/usage/Finding.java

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
package com.brianway.learning.java8.streamapi.usage;
2+
3+
import com.brianway.learning.java8.streamapi.Dish;
4+
import static com.brianway.learning.java8.streamapi.Dish.menu;
5+
6+
import java.util.Optional;
7+
8+
/**
9+
* 查找和匹配
10+
*/
11+
public class Finding {
12+
13+
public static void main(String...args){
14+
if(isVegetarianFriendlyMenu()){
15+
System.out.println("Vegetarian friendly");
16+
}
17+
18+
System.out.println(isHealthyMenu());
19+
System.out.println(isHealthyMenu2());
20+
21+
Optional<Dish> dish = findVegetarianDish();
22+
dish.ifPresent(d -> System.out.println(d.getName()));
23+
}
24+
25+
private static boolean isVegetarianFriendlyMenu(){
26+
return menu.stream().anyMatch(Dish::isVegetarian);
27+
}
28+
29+
private static boolean isHealthyMenu(){
30+
return menu.stream().allMatch(d -> d.getCalories() < 1000);
31+
}
32+
33+
private static boolean isHealthyMenu2(){
34+
return menu.stream().noneMatch(d -> d.getCalories() >= 1000);
35+
}
36+
37+
private static Optional<Dish> findVegetarianDish(){
38+
return menu.stream().filter(Dish::isVegetarian).findAny();
39+
}
40+
41+
}

‎java8/src/main/java/com/brianway/learning/java8/streamapi/Mapping.java renamed to ‎java8/src/main/java/com/brianway/learning/java8/streamapi/usage/Mapping.java

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
package com.brianway.learning.java8.streamapi;
1+
package com.brianway.learning.java8.streamapi.usage;
22

3+
import com.brianway.learning.java8.streamapi.Dish;
34
import static com.brianway.learning.java8.streamapi.Dish.menu;
45
import static java.util.stream.Collectors.toList;
56

@@ -9,6 +10,7 @@
910
/**
1011
* 使用流-映射
1112
* 注意扁平映射
13+
* flatMap 的效果:各个数组不是分别映射成一个流,而是映射成 流的内容
1214
*/
1315
public class Mapping {
1416

@@ -44,5 +46,15 @@ public static void main(String... args) {
4446
.filter(pair -> (pair[0] + pair[1]) % 3 == 0)
4547
.collect(toList());
4648
pairs.forEach(pair -> System.out.println("(" + pair[0] + ", " + pair[1] + ")"));
49+
50+
// flatMap
51+
List<int[]> pairs2 = numbers1.stream()
52+
.flatMap(i -> numbers2.stream()
53+
.filter(j -> (i + j) % 3 == 0)
54+
.map(j -> new int[] {i, j})
55+
)
56+
.collect(toList());
57+
System.out.println("----------");
58+
pairs2.forEach(pair -> System.out.println("(" + pair[0] + ", " + pair[1] + ")"));
4759
}
4860
}

‎java8/src/main/java/com/brianway/learning/java8/streamapi/usage/Reducing.java

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
package com.brianway.learning.java8.streamapi.usage;
2+
3+
import com.brianway.learning.java8.streamapi.Dish;
4+
import static com.brianway.learning.java8.streamapi.Dish.menu;
5+
6+
import java.util.Arrays;
7+
import java.util.List;
8+
import java.util.Optional;
9+
10+
/**
11+
* 归约
12+
*/
13+
public class Reducing {
14+
15+
public static void main(String... args) {
16+
17+
List<Integer> numbers = Arrays.asList(3, 4, 5, 1, 2);
18+
int sum = numbers.stream().reduce(0, (a, b) -> a + b);
19+
System.out.println(sum);
20+
21+
int sum2 = numbers.stream().reduce(0, Integer::sum);
22+
System.out.println(sum2);
23+
24+
int max = numbers.stream().reduce(0, Integer::max);
25+
System.out.println(max);
26+
27+
Optional<Integer> min = numbers.stream().reduce(Integer::min);
28+
min.ifPresent(System.out::println);
29+
30+
int calories = menu.stream()
31+
.map(Dish::getCalories)
32+
.reduce(0, Integer::sum);
33+
System.out.println("Number of calories:" + calories);
34+
}
35+
}

0 commit comments

Comments
 (0)