Java8Stream forEach不能return |
您所在的位置：网站首页 › for循环里的return一个对象可以正常返回吗为什么 › Java8Stream forEach不能return |
Java8Stream forEach不能return
|
Java8新特性：Stream，Stream 提供了新的方法 'forEach' 来迭代流中的每个数据。 目录 forEach为什么不能return？ Stream操作的两个基础特征 Stream的操作符 Stream记录操作的方式 forEach为什么不能return？根本原因：在lambda表达式中的return并不会终止循环，这是由于lambda的底层实现导致的 Stream（流）是一个来自数据源的元素队列并支持聚合操作 Stream操作的两个基础特征 Pipelining: 中间操作都会返回流对象本身。 这样多个操作可以串联成一个管道， 如同流式风格（fluent style）。 这样做可以对操作进行优化， 比如延迟执行(laziness)和短路( short-circuiting)。内部迭代： 以前对集合遍历都是通过Iterator或者For-Each的方式, 显式的在集合外部进行迭代， 这叫做外部迭代。 Stream提供了内部迭代的方式， 通过访问者模式(Visitor)实现。 Stream的操作符Stream的操作符大体上分为两种：中间操作符和终止操作符 中间操作符 对于数据流来说，中间操作符在执行制定处理程序后，数据流依然可以传递给下一级的操作符。 中间操作符包含8种(排除了parallel,sequential,这两个操作并不涉及到对数据流的加工操作)： 1. map(mapToInt,mapToLong,mapToDouble) 转换操作符，把比如A->B，这里默认提供了转int，long，double的操作符。 用于映射每个元素到对应的结果 List numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5); // 获取对应的平方数 List squaresList = numbers.stream().map( i -> i*i).distinct().collect(Collectors.toList());2. flatmap(flatmapToInt,flatmapToLong,flatmapToDouble) 拍平操作比如把 int[]{2,3,4} 拍平 变成 2，3，4 也就是从原来的一个数据变成了3个数据，这里默认提供了拍平成int,long,double的操作符。 3. limit 限流操作，比如数据流中有10个 我只要出前3个就可以使用。 Random random = new Random(); // 使用 limit 方法打印出 10 条数据 random.ints().limit(10).forEach(System.out::println);4. distint 去重操作，对重复元素去重，底层使用了equals方法。 5. filter 过滤操作，把不想要的数据过滤。 Liststrings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); // 获取空字符串的数量 long count = strings.stream().filter(string -> string.isEmpty()).count();6. peek 挑出操作，如果想对数据进行某些操作，如：读取、编辑修改等。 7. skip 跳过操作，跳过某些元素。 8. sorted(unordered) 排序操作，对元素排序，前提是实现Comparable接口，当然也可以自定义比较器。 Random random = new Random(); random.ints().limit(10).sorted().forEach(System.out::println);终止操作符 数据经过中间加工操作，就轮到终止操作符上场了；终止操作符就是用来对数据进行收集或者消费的，数据到了终止操作这里就不会向下流动了，终止操作符只能使用一次。 1. collect 收集操作，将所有数据收集起来，这个操作非常重要，官方的提供的Collectors 提供了非常多收集器，可以说Stream 的核心在于Collectors。 List filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList()); String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", "));2. count 统计操作，统计最终的数据个数。 3. findFirst、findAny 查找操作，查找第一个、查找任何一个 返回的类型为Optional。 Optional aa = strs.stream().filter(str -> !str.equals("a")).findFirst(); Optional bb = strs.stream().filter(str -> !str.equals("a")).findAny();4. noneMatch、allMatch、anyMatch 匹配操作，数据流中是否存在符合条件的元素 返回值为bool 值。 5. min、max 最值操作，需要自定义比较器，返回数据流中最大最小的值。 Optional max = strs.stream().max((o1, o2) -> o1.compareTo(o2))6. reduce 规约操作，将整个数据流的值规约为一个值，count、min、max底层就是使用reduce。 7. forEach、forEachOrdered 遍历操作，这里就是对最终的数据进行消费了。 8. toArray 数组操作，将数据流的元素转换成数组。 Stream记录操作的方式图中通过Collection.stream()方法得到Head也就是stage0，紧接着调用一系列的中间操作，不断产生新的Stream。这些Stream对象以双向链表的形式组织在一起，构成整个流水线，由于每个Stage都记录了前一个Stage和本次的操作以及回调函数，依靠这种结构就能建立起对数据源的所有操作。这就是Stream记录操作的方式。 |
【本文地址】
今日新闻 |
推荐新闻 |