Java中的流式编程问题

2023-12-14 08:49:14 作者：不喜欢吃猫的鱼

这篇文章主要介绍了Java中的流式编程问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

注意：这个特效是在Java8之后才引进的就是说 jdk8之前是没有的

一. 基本概念

1.1 为什么加入集合的流式操作

JDK8 的Stream 是一个受到函数式编程和多核时代影响而产生的东西。很多时候我们需要到底层返回数据，上层再对数据进行遍历，进行一些数据统计，但是之前的Java API 中很少有这种方法，这就需要我们自己来 Iterator 来遍历，如果JDK 能够为我们提供一些这种方法，并且能够为我们优化就好了。

所以JDK8加入了 java.util.stream包，实现了集合的流式操作，流式操作包括集合的过滤，排序，映射等功能。根据流的操作性，又可以分为串行流和并行流。

根据操作返回的结果不同，流式操作又分为中间操作和最终操作。大大方便了我们对于集合的操作。

最终操作：返回一特定类型的结果。
中间操作：返回流本身。

1.2 什么是流

Stream 不是集合元素，也不是数据结构，它相当于一个高级版本的 Iterator，不可以重复遍历里面的数据，像水一样，流过了就一去不复返。

它和普通的 Iterator 不同的是，它可以并行遍历，普通的 Iterator 只能是串行，在一个线程中执行。

二. 串行流和并行流

串行流操作在一个线程中依次完成。

并行流在多个线程中完成，主要利用了 JDK7 的 Fork/Join 框架来拆分任务和加速处理。

相比串行流，并行流可以很大程度提高程序的效率。

三. 中间操作和最终操作

中间操作：

filter()：对元素进行过滤
sorted()：对元素排序
map()：元素映射
distinct()：去除重复的元素

最终操作：

forEach()：遍历每个元素。
reduce()：把Stream 元素组合起来。例如，字符串拼接，数值的 sum，min，max ，average 都是特殊的 reduce。
collect()：返回一个新的集合。
min()：找到最小值。
max()：找到最大值。

废话不多说直接上代码：

public static void main(String[] args) {
   List<String> list = new ArrayList();
   list.add("a");
   list.add("b");
   list.add("c");
   list.add("d");
   list.add("d");
   list.add("d");
   list.add("d");
   list.add("d");
   list.add("d");
   list.add("e");
   list.add("f");
   list.add("aa");
   list.add("faaa");
   System.out.println("----对集合数据的过滤，根据给到的条件筛选过滤----");
   list.stream().filter(param -> !param.contains("a")).forEach(System.out::println);

   System.out.println("----对集合数据进行排序,默认的是升序排列----");
   list.stream().sorted().forEach(System.out::println);


   System.out.println("----自定义排序方式----");//注:这里是通过 Stream<T> sorted(Comparator<? super T> comparator); 这个方法
   list.stream().sorted((p1,p2) -> p1.hashCode() <p2.hashCode() ? 1 : -1).forEach(System.out::println);


   System.out.println("----对于集合的每个元素可以按照规则变成相应的元素,这里是把包含a的元素替换成了1,其他的不变----");
   list.stream().map(param -> param.contains("a") ? 1 : param).forEach(System.out ::println);



   System.out.println("----对于集合中重复的数据进行去重,把相同的数据去除,这里去除了d的重复元素----");
   list.stream().distinct().forEach(System.out ::println);


   System.out.println("----reduce是把集合里的数据组合起来,这里是把所有的元素组合成一个新的字符串----");
   System.out.println(list.stream().reduce((p1,p2) -> p1+p2).get());

   
   
   System.out.println("----collect是将原先的集合数据根据给定的条件筛选重新生成一个新的list集合返回----");
   list.stream().filter(p -> !p.contains("a")).collect(Collectors.toList()).forEach(System.out::println);
}

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。