JavaSE之 I/O流(一) stream

简介: JavaSE之 I/O流(一) stream

Stream

概述

Stream 流其实就是一根传送带,元素在上面可以被 Stream 流操作

  • 可以解决已有集合类库或者数组 API 的弊端
  • Stream 流简化集合和数组的操作
  • 链式编程
 list.stream().filter(new Predicate<String>() {
             @Override
             public boolean test(String s) {
                 return s.startsWith("张");
             }
         });
 ​
 list.stream().filter(s -> s.startsWith("张"));

获取流

集合获取 Stream 流用:default Stream<E> stream()

数组:Arrays.stream(数组) / Stream.of(数组);

 // Collection集合获取Stream流。
 Collection<String> c = new ArrayList<>();
 Stream<String> listStream = c.stream();
 ​
 // Map集合获取流
 // 先获取键的Stream流。
 Stream<String> keysStream = map.keySet().stream();
 // 在获取值的Stream流
 Stream<Integer> valuesStream = map.values().stream();
 // 获取键值对的Stream流(key=value: Map.Entry<String,Integer>)
 Stream<Map.Entry<String,Integer>> keyAndValues = map.entrySet().stream();
 ​
 //数组获取流
 String[] arr = new String[]{"Java", "JavaEE" ,"Spring Boot"};
 Stream<String> arrStream1 = Arrays.stream(arr);
 Stream<String> arrStream2 = Stream.of(arr);

常用API

方法名 说明
void forEach(Consumer<? super T> action) 逐一处理(遍历)
long count 返回流中的元素数
Stream filter(Predicate<? super T> predicate) 用于对流中的数据进行过滤
Stream limit(long maxSize) 返回此流中的元素组成的流,截取前指定参数个数的数据
Stream skip(long n) 跳过指定参数个数的数据,返回由该流的剩余元素组成的流
Stream map(Function<? super T,? extends R> mapper) 加工方法,将当前流中的 T 类型数据转换为另一种 R 类型的流
static Stream concat(Stream a, Stream b) 合并 a 和 b 两个流为一个,调用 Stream.concat(s1,s2)
Stream distinct() 返回由该流的不同元素组成的流

终结方法

终结方法:Stream 调用了终结方法,流的操作就全部终结,不能继续使用,如 foreach,count 方法等

非终结方法:每次调用完成以后返回一个新的流对象,可以继续使用,支持链式编程

 // foreach终结方法
 list.stream().filter(s -> s.startsWith("张"))
     .filter(s -> s.length() == 3).forEach(System.out::println);

收集流

收集 Stream:把 Stream 流的数据转回到集合中去

  • Stream 流:工具
  • 集合:目的

Stream 收集方法:R collect(Collector collector) 把结果收集到集合中

Collectors 方法:

  • public static <T> Collector toList():把元素收集到 List 集合中
  • public static <T> Collector toSet():把元素收集到 Set 集合中
  • public static Collector toMap(Function keyMapper,Function valueMapper):把元素收集到 Map 集合中
  • Object[] toArray():把元素收集数组中
  • public static Collector groupingBy(Function<? super T, ? extends K> classifier):分组+
目录
相关文章
|
5月前
|
人工智能 IDE JavaScript
JetBrains WebStorm 2025.1 发布 - 最智能的 JavaScript IDE
JetBrains WebStorm 2025.1 (macOS, Linux, Windows) - 最智能的 JavaScript IDE
194 6
JetBrains WebStorm 2025.1 发布 - 最智能的 JavaScript IDE
|
6月前
|
人工智能 监控 数据挖掘
利用DeepSeek帮我做金融理财
本篇文章将介绍如何搭建一套基于 XXL-JOB + Deepseek 的定时数据分析系统,帮你做一个智能的金融理财助手。
利用DeepSeek帮我做金融理财
|
7月前
|
数据可视化 数据挖掘 BI
MATLAB学习之旅:数据统计与分析
在MATLAB中,我们掌握了数据导入、处理及插值拟合等基础技能。接下来,我们将深入数据统计与分析领域,学习描述性统计量(如均值、标准差)、数据分布分析(如直方图、正态概率图)、数据排序与排名、数据匹配查找以及数据可视化(如箱线图、散点图)。这些工具帮助我们挖掘数据中的有价值信息,揭示数据的奥秘,为后续数据分析打下坚实基础。
|
XML 监控 Java
Spring Cloud全解析:熔断之Hystrix简介
Hystrix 是由 Netflix 开源的延迟和容错库,用于提高分布式系统的弹性。它通过断路器模式、资源隔离、服务降级及限流等机制防止服务雪崩。Hystrix 基于命令模式,通过 `HystrixCommand` 封装对外部依赖的调用逻辑。断路器能在依赖服务故障时快速返回备选响应,避免长时间等待。此外,Hystrix 还提供了监控功能,能够实时监控运行指标和配置变化。依赖管理方面,可通过 `@EnableHystrix` 启用 Hystrix 支持,并配置全局或局部的降级策略。结合 Feign 可实现客户端的服务降级。
673 23
|
传感器 数据采集 监控
什么是物联网通信网关?
物联网通信网关是连接物联网设备与云或外部网络的关键桥梁。
838 2
|
机器学习/深度学习 搜索推荐 算法
高并发推荐系统架构设计-1 基本介绍
【5月更文挑战第5天】推荐系统是信息过滤工具,通过处理物料数据和行为日志,运用预处理、特征工程、算法模型学习用户兴趣,实现个性化推荐。在线架构包括AB分流、多路召回、模型排序和业务规则重排序。旧版线上架构由C++编写的API和engine服务组成,HTTP请求经SLB、Nginx、FastCGI到达服务程序,召回和排序服务处理推荐。存在并发瓶颈问题。
324 1
|
JavaScript 前端开发 IDE
TypeScript:前端世界的“甜蜜烦恼”——究竟该不该用?
TypeScript:前端世界的“甜蜜烦恼”——究竟该不该用?
181 0
|
并行计算 Ubuntu Docker
MPI环境配置
不读mpi4py势必学不会sgd和m/s模型的修改处, 所以先得将修改看明白;使用mpi4py可是不容易, 毕竟很难有多个Ubuntu的环境所以得学会docker 命令。
397 0
|
缓存 NoSQL 算法
Redis主从加哨兵模式集群部署2
Redis主从加哨兵模式集群部署2
226 0
|
存储 监控 数据可视化
Zabbix分布式监控系统从理论到实践
Zabbix分布式监控系统从理论到实践
398 0