HoRain云--Java Stream 自定义 Collector：从 collectingAndThen 到并行收集-北京尧图网络

本文讲解 Java Stream Collector 原理包括内置收集器、自定义 Collector、combiner、并行收集和实战案例。正文1. Collector 接口java复制下载public interface CollectorT, A, R { SupplierA supplier(); BiConsumerA, T accumulator(); BinaryOperatorA combiner(); FunctionA, R finisher(); SetCharacteristics characteristics(); }T元素类型A累加器类型R结果类型2. 内置收集器java复制下载list.stream().collect(Collectors.toList()); list.stream().collect(Collectors.toSet()); list.stream().collect(Collectors.toMap(User::getId, User::getName)); list.stream().collect(Collectors.groupingBy(User::getCity)); list.stream().collect(Collectors.joining(, )); list.stream().collect(Collectors.counting());3. 自定义 Collectorjava复制下载public class ImmutableListCollectorT implements CollectorT, ListT, ListT { public SupplierListT supplier() { return ArrayList::new; } public BiConsumerListT, T accumulator() { return List::add; } public BinaryOperatorListT combiner() { return (a, b) - { a.addAll(b); return a; }; } public FunctionListT, ListT finisher() { return Collections::unmodifiableList; } public SetCharacteristics characteristics() { return Collections.emptySet(); } }使用java复制下载ListString result stream.collect(new ImmutableListCollector());4. Collector.of 简化java复制下载CollectorUser, ?, MapString, Integer collector Collector.of( HashMap::new, (map, user) - map.merge(user.getCity(), 1, Integer::sum), (m1, m2) - { m2.forEach((k, v) - m1.merge(k, v, Integer::sum)); return m1; } );5. CharacteristicsCONCURRENT并行时可多线程累加同一容器。UNORDERED不保证顺序。IDENTITY_FINISHfinisher 为恒等函数。6. collectingAndThenjava复制下载ListString unmodifiable list.stream() .collect(Collectors.collectingAndThen(Collectors.toList(), Collections::unmodifiableList));7. teeingJava 12同时收集两个结果java复制下载record Stats(long count, double sum) {} Stats stats list.stream().collect(Collectors.teeing( Collectors.counting(), Collectors.summingDouble(Item::getPrice), Stats::new ));8. 实战分组后排序java复制下载MapString, ListUser result users.stream() .collect(Collectors.groupingBy( User::getCity, Collectors.collectingAndThen( Collectors.toList(), list - list.stream() .sorted(Comparator.comparing(User::getAge)) .toList() ) ));9. 并行收集java复制下载MapString, Long counts list.parallelStream() .collect(Collectors.groupingByConcurrent(User::getCity, Collectors.counting()));并行时使用groupingByConcurrent提升性能。10. 常见坑自定义 Collector 未正确实现 combiner并行结果错误。使用有状态 lambda。toMap 键冲突未处理。并行流与线程安全容器混用。11. 总结自定义 Collector 让 Stream 收集更灵活。理解 supplier、accumulator、combiner、finisher 后可以实现复杂聚合逻辑。

HoRain云--Java Stream 自定义 Collector：从 collectingAndThen 到并行收集

相关推荐

HoRain云--Spring Boot 配置管理进阶：多环境、加密、动态刷新与配置中心

一个.class文件是怎么被JVM跑起来的？类加载机制+双亲委派一篇讲透

网盘资源管理实战：从EVA剧场版收藏到跨平台文件同步与备份

更多资讯

PL/SQL Developer免Oracle客户端实战配置指南

多功能在线报价系统开发实战：PHP+MySQL实现从数据表到PDF导出

Cocos Creator回合制战斗系统：调度器与状态机设计实战

Substrate 区块链开发实战：从模块化架构到 Pallet 开发与升级

CRMEB 标准版系统（Java）v3.2 公测版发布

嵌入式驱动开发到底忙啥？设备树与内核宏实战解析

今日更新

AI元人文：从工具使用到思维重构的深度探索

Python+CNN车牌识别实战：从数据预处理到模型训练与部署

Vim基础操作全攻略：保存退出、模式切换与高频命令实战

本周精选

深入解析Transformer多头注意力机制与工程优化

OpenClaw 的 Skills 跑学习任务，模型通道改到 TaoToken 通道行不行？

ChatGPT报错Oops, an error occurred! 全链路排查指南

本月热门

基于YOLO的焊缝缺陷检测：从数据标注到工业部署全流程实践

分布式服务的决策记录

创业产品的首版范围

读完文章，想聊聊您的网站？