当前位置: 首页 > news >正文

Java8 Stream流:Stream流的思想和获取Stream流

Stream流的思想

Stream流是Java 8引入的一种处理集合数据的抽象概念,其核心思想是将数据源(如集合、数组等)转化为流,通过链式调用一系列中间操作(如过滤、映射、排序等)对数据进行处理,最后通过终端操作(如收集、计数等)生成结果。Stream流强调函数式编程惰性求值,能够高效、简洁地处理数据。

获取Stream流的方法

单列集合获取Stream流

单列集合(如ListSet)可以直接调用stream()方法获取流。

List<String> list = Arrays.asList("Java", "Python", "C++");
Stream<String> stream = list.stream();

实例:

public class StreamDemo2 {public static void main(String[] args) {
/*单列集合      default Stream<E> stream()                           Collection中的默认方法双列集合      无                                                   无法直接使用stream流数组          public static <T> Stream<T> stream(T[] array)        Arrays工具类中的静态方法一堆零散数据   public static<T> Stream<T> of(T... values)           Stream接口中的静态方法
*///1.单列集合获取Stream流ArrayList<String> list = new ArrayList<>();Collections.addAll(list,"a","b","c","d","e");/*//获取到一条流水线,并把集合中的数据放到流水线上Stream<String> stream1 = list.stream();//使用终结方法打印一下流水线上的所有数据stream1.forEach(new Consumer<String>() {@Overridepublic void accept(String s) {//s:依次表示流水线上的每一个数据System.out.println(s);}});*/list.stream().forEach(s -> System.out.println(s));}
}
双列集合获取Stream流

双列集合(如Map)需先转换为单列集合(如entrySetkeySetvalues),再获取流。

Map<String, Integer> map = new HashMap<>();
map.put("A", 1);
map.put("B", 2);// 获取键的流
Stream<String> keyStream = map.keySet().stream();
// 获取值的流
Stream<Integer> valueStream = map.values().stream();
// 获取键值对的流
Stream<Map.Entry<String, Integer>> entryStream = map.entrySet().stream();

实例:

public class StreamDemo3 {public static void main(String[] args) {//双列集合      无                                                   无法直接使用stream流//1.创建双列集合HashMap<String,Integer> hm = new HashMap<>();//2.添加数据hm.put("aaa",111);hm.put("bbb",222);hm.put("ccc",333);hm.put("ddd",444);//3.第一种获取stream流//hm.keySet().stream().forEach(s -> System.out.println(s));//4.第二种获取stream流hm.entrySet().stream().forEach(s-> System.out.println(s));}
}
数组获取Stream流

通过Arrays.stream()方法或Stream.of()方法获取流。

String[] array = {"Apple", "Banana", "Orange"};// 方式1
Stream<String> stream1 = Arrays.stream(array);
// 方式2
Stream<String> stream2 = Stream.of(array);

实例:

public class StreamDemo4 {public static void main(String[] args) {// 数组          public static <T> Stream<T> stream(T[] array)        Arrays工具类中的静态方法//1.创建数组int[] arr1 = {1,2,3,4,5,6,7,8,9,10};String[] arr2 = {"a","b","c"};//2.获取stream流// Arrays.stream(arr1).forEach(s-> System.out.println(s));//System.out.println("============================");//Arrays.stream(arr2).forEach(s-> System.out.println(s));//System.out.println("============================");//注意://Stream接口中静态方法of的细节//方法的形参是一个可变参数,可以传递一堆零散的数据,也可以传递数组//但是数组必须是引用数据类型的,如果传递基本数据类型,是会把整个数组当做一个元素,放到Stream当中。Stream.of(arr1).forEach(s-> System.out.println(s));//[I@41629346}
}
零散数据获取Stream流

使用Stream.of()直接生成流。

Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5);

实例:

public class StreamDemo5 {public static void main(String[] args) {//一堆零散数据   public static<T> Stream<T> of(T... values)           Stream接口中的静态方法Stream.of(1,2,3,4,5).forEach(s-> System.out.println(s));Stream.of("a","b","c","d","e").forEach(s-> System.out.println(s));}
}
其他方式
  1. 生成无限流:通过Stream.iterate()Stream.generate()

    // 从0开始,每次加2
    Stream<Integer> infiniteStream = Stream.iterate(0, n -> n + 2);
    // 生成随机数流
    Stream<Double> randomStream = Stream.generate(Math::random);
    

  2. 文件流:通过Files.lines()读取文件内容为流。

    Path path = Paths.get("file.txt");
    Stream<String> fileStream = Files.lines(path);
    

  3. 基本类型流:如IntStreamLongStreamDoubleStream

    IntStream intStream = IntStream.of(1, 2, 3);
    

示例整合

以下代码展示不同数据源如何获取Stream流并操作:

import java.util.*;
import java.util.stream.*;
import java.nio.file.*;public class StreamExample {public static void main(String[] args) {// 单列集合List<String> list = Arrays.asList("Java", "Python", "C++");list.stream().filter(s -> s.startsWith("J")).forEach(System.out::println);// 双列集合Map<String, Integer> map = Map.of("A", 1, "B", 2);map.entrySet().stream().filter(e -> e.getValue() > 1).forEach(e -> System.out.println(e.getKey()));// 数组String[] array = {"Apple", "Banana"};Arrays.stream(array).map(String::toUpperCase).forEach(System.out::println);// 零散数据Stream.of(1, 2, 3).map(n -> n * 2).forEach(System.out::println);}
}

Stream流的核心优势在于链式操作惰性执行,能够高效处理大量数据且代码可读性强。

http://www.lqws.cn/news/519607.html

相关文章:

  • 深入浅出:RocketMQ与Kafka的双剑合璧,实现高可用与高吞吐
  • 服务器不支持PUT,DELETE 的解决方案
  • python爬虫框架scrapy学习记录
  • 打造属于你的AI智能体,从数据开始 —— 使用 Bright Data MCP+Trae快速构建垂直智能体
  • 量学云讲堂2025朱永海慢牛开启第58期视频课程
  • 卡萨帝发布AI深度科技:实现从守护生活到守护文明的升级
  • Linux系统之Nginx反向代理与缓存
  • Aurora MySQL 3.05/3.06/3.07版本即将停用,全局数据库升级实战指南
  • 逆序对的数量
  • 基于MATLAB的BP神经网络的心电图分类方法应用
  • pyhton基础【16】函数进阶二
  • 仿Apple官网设计风格
  • HCIA-IP路由基础
  • 鸿蒙OH南向开发 轻量系统内核(LiteOS-M)【Shell】
  • 实测对比:用 Lynx 做网页,效率比传统工具提升 270% 的底层逻辑
  • 【Oracle学习笔记】4.索引(Index)
  • 【大厂机试题解法笔记】可以组成网络的服务器
  • FPGA基础 -- Verilog 格雷码(Gray Code)计数器设计与原理解析
  • 开疆智能CCLinkIE转ModbusTCP网关连接脉冲计数器配置案例
  • MySQL之存储过程详解
  • 自动化测试--Appium和ADB及常用指令
  • 分布式环境下 Spring Boot 项目基于雪花算法的唯一 ID 生成方案
  • php后台增加权限控制
  • LangGraph开篇-LangGraph 核心元素简介(官网文档解读)
  • Spring Web MVC ①
  • 用 Boost 库解析 .ini 和 .json 文件时的“坑”:注释导致的解析错误与解决方案
  • 湖北理元理律师事务所:债务规划中的法律与心理双轨模型
  • 如何在 Manjaro Linux 上安装 Docker 容器
  • OpenCV——cv::floodFill
  • 卷积神经网络(Convolutional Neural Network, CNN)