文交所网站建设方案,重庆网站建设seo公司哪家好,wordpress首页调用最新文章,爬取旅游网站数据并进行分析前些天发现了十分不错的人工智能学习网站#xff0c;通俗易懂#xff0c;风趣幽默#xff0c;没有广告#xff0c;分享给大家#xff0c;大家可以自行看看。#xff08;点击跳转人工智能学习资料#xff09; 文章目录Stream 概述Stream 实例化Stream 中间操作Stream 终止…前些天发现了十分不错的人工智能学习网站通俗易懂风趣幽默没有广告分享给大家大家可以自行看看。点击跳转人工智能学习资料 文章目录Stream 概述Stream 实例化Stream 中间操作Stream 终止操作Stream 概述
Stream API ( java.util.stream) 把真正的函数式编程风格引入到Java中。这是目前为止对Java类库最好的补充因为Stream API可以极大提供Java程序员的生产力让程序员写出高效率、干净、简洁的代码。
Stream 是 Java8 中处理集合的关键抽象概念它可以指定你希望对集合进行的操作可以执行非常复杂的查找、过滤和映射数据等操作。 使用Stream API 对集合数据进行操作就类似于使用 SQL 执行的数据库查询。也可以使用 Stream API 来并行执行操作。简言之Stream API提供了一种高效且易于使用的处理数据的方式。
实际开发中项目中多数数据源都来自于MysqlOracle等。但随着数据源丰富有MongDBRadis等这些NoSQL的数据就需要Java层面去处理。
Stream 和 Collection 集合的区别Collection 是一种静态的内存数据结构而Stream 是有关计算的。前者是主要面向内存存储在内存中后者主要是面向 CPU通过 CPU 实现计算。
Stream 是数据渠道用于操作数据源集合、数组等所生成的元素序列。 “集合讲的是数据Stream讲的是计算。”
注意 ①Stream 不会存储元素。 ②Stream 不会改变源对象。其会返回一个持有结果的新Stream。 ③Stream 操作是延迟执行的。其会等到需要结果的时候才执行。
Stream 操作的三个步骤 ①Stream 实例化创建一个数据源如集合、数组获取一个流。 ②中间操作一个中间操作链对数据源的数据进行处理。 ③终止操作(终端操作)一旦执行终止操作就执行中间操作链并产生结果。之后不能再被使用需要的话需要另一个Stream。 Stream 实例化
1、方式一通过集合 Java8 中的 Collection 接口被扩展提供了两个获取流的方法
import java.util.ArrayList;
import java.util.stream.Stream;public class StreamAPITest {public static void main(String[] args) {ListString arrayList new ArrayList();arrayList.add(aa);arrayList.add(哈哈);arrayList.add(99);//返回一个顺序流即aa-哈哈-99StreamString stream1 arrayList.stream();//返回一个并行流StreamString stream2 arrayList.parallelStream();}
}2、方式二通过数组 Java8 中的 Arrays 的静态方法 stream() 可以获取数组流
import java.util.Arrays;
import java.util.stream.Stream;public class StreamAPITest {public static void main(String[] args) {Double[] doubles {1.1, 2.0, 4.3, 9.9};StreamDouble stream Arrays.stream(doubles);}
}3、方式三通过Stream的of() 调用Stream类静态方法 of()通过显示值创建一个流其可接收任意数量的参数
import java.util.stream.Stream;public class StreamAPITest {public static void main(String[] args) {Double[] doubles {1.1, 2.0, 4.3, 9.9};StreamDouble doubles1 Stream.of(doubles);Stream? extends Number stream Stream.of(1, 2, 3, 9.9);}
}4、方式四创建无限流 可以使用静态方法 Stream.iterate() 和 Stream.generate() 创建无限流
import java.util.stream.Stream;public class StreamAPITest {public static void main(String[] args) {// 迭代// public staticT StreamT iterate(final T seed, final UnaryOperatorT f)StreamInteger stream Stream.iterate(0, x - x 2);stream.limit(10).forEach(System.out::println);// 生成// public staticT StreamT generate(SupplierT s)StreamDouble stream1 Stream.generate(Math::random);stream1.limit(10).forEach(System.out::println);}
}Stream 中间操作
多个中间操作可以连接起来形成一个流水线除非流水线上触发终止操作否则中间操作不会执行任何的处理。而在终止操作时一次性全部处理称为“惰性求值”。
1、筛选与切片
import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListString arrayList Arrays.asList(aa,bb,cc,aa);StreamString stream arrayList.stream();stream.filter(e - !e.equals(aa)).forEach(System.out :: println); //bb ccSystem.out.println();arrayList.stream().limit(2).forEach(System.out :: println); //aa bbSystem.out.println();arrayList.stream().skip(2).forEach(System.out :: println); //cc aaSystem.out.println();arrayList.stream().distinct().forEach(System.out :: println); //aa bb cc}
}2、映射
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListString arrayList Arrays.asList(aa,bb,cc,aa);StreamString stream arrayList.stream();stream.map(x - x.toUpperCase()).forEach(System.out :: println); //AA BB CC AASystem.out.println();arrayList.stream().map(StreamAPITest::fromStringToStream).forEach(System.out :: println); //类似于add()arrayList.stream().flatMap(StreamAPITest::fromStringToStream).forEach(System.out :: println); //类似于addAll()}public static StreamCharacter fromStringToStream(String str){ArrayListCharacter arrayList new ArrayList();for (Character c : str.toCharArray()){arrayList.add(c);}return arrayList.stream();}
}3、排序
import java.util.Arrays;
import java.util.List;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListInteger list Arrays.asList(2, -9, 0, 22, 6, -1);list.stream().sorted().forEach(System.out::println);System.out.println();list.stream().sorted((e1,e2) - -Integer.compare(e1,e2)).forEach(System.out :: println);}
}Stream 终止操作
终端操作会从流的流水线生成结果。其结果可以是任何不是流的值例如List、Integer甚至是 void 。流进行了终止操作后不能再次使用。
1、匹配与查找
import java.util.Arrays;
import java.util.List;
import java.util.Optional;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListInteger list Arrays.asList(2, -9, 0, 22, 6, -1);boolean allMatch list.stream().allMatch(e - e 0);System.out.println(allMatch);boolean anyMatch list.stream().anyMatch(e - e 0);System.out.println(anyMatch);boolean noneMatch list.stream().noneMatch(e - e 100);System.out.println(noneMatch);System.out.println();OptionalInteger first list.stream().sorted().findFirst();System.out.println(first);OptionalInteger any list.parallelStream().findAny();System.out.println(any);System.out.println();long count list.stream().filter(e - e 0).count();System.out.println(count);System.out.println();OptionalInteger max list.stream().max(Integer :: compare);System.out.println(max);OptionalInteger min list.stream().min((e1, e2) - Integer.compare(e1, e2));System.out.println(min);System.out.println();list.stream().forEach(System.out :: println);}
}2、归约 map 和 reduce 的连接通常称为 map-reduce 模式因 Google 用它来进行网络搜索而出名。
import java.util.Arrays;
import java.util.List;
import java.util.Optional;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListInteger list Arrays.asList(2, -9, 0, 22, 6, -1);Integer reduce1 list.stream().reduce(0, Integer::sum);Integer reduce11 list.stream().reduce(0, (e1,e2) - e1 e2);System.out.println(reduce1);System.out.println(reduce11);OptionalInteger reduce2 list.stream().reduce(Integer::sum);System.out.println(reduce2);}
}3、收集 Collector 接口中方法的实现决定了如何对流执行收集的操作(如收集到 List、Set、 Map)。另外 Collectors 实用类提供了很多静态方法可以方便地创建常见收集器实例具体方法与实例如下表
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;/*** Author: Yeman* Date: 2021-10-05-17:25* Description:*/
public class StreamAPITest {public static void main(String[] args) {ListInteger list Arrays.asList(2, -9, 0, 22, 6, -1);ListInteger collect list.stream().filter(e - e 0).collect(Collectors.toList());collect.forEach(System.out :: println); //2 22 6}
}
