Collectors.groupingBy分组后乱序问题

简介: Collectors.groupingBy分组后乱序问题

问题描述:

当我们对List根据时间排序,然后根据某个字段分组后,会产生乱序的问题。

解决办法:

因为Collectors.groupingBy分组后默认返回HashMap类型,我们修改为LinkedHashMap即可。


Collectors.groupingBy部分源码:


//一个参数 classifier
public static <T, K> Collector<T, ?, Map<K, List<T>>>
groupingBy(Function<? super T, ? extends K> classifier) {
    return groupingBy(classifier, toList());
}
//两个参数 classifier 和 downstream
public static <T, K, A, D>
    Collector<T, ?, Map<K, D>> groupingBy(Function<? super T, ? extends K> classifier,
                                          Collector<? super T, A, D> downstream) {
    return groupingBy(classifier, HashMap::new, downstream);
}
//三个参数 classifier 和 mapFactory 和 downstream
public static <T, K, D, A, M extends Map<K, D>>
    Collector<T, ?, M> groupingBy(Function<? super T, ? extends K> classifier,
                                  Supplier<M> mapFactory,
                                  Collector<? super T, A, D> downstream) {..}

通过源码可以看到,我们可以上传三个参数,分别是:

classifier:按照什么分组

mapFactory:最后的结果返回的容器

downstream:收集分类的结果的收集器

当我们只上传一个参数后,默认第二个参数downstream是HashMap::new,也就是返回结果用HashMap存储,我们想返回HashMap就需要调用三个参数的方法,自定义downstream为LinkedHashMap::new即可。


样例:


LinkedHashMap<String,List<ProcessDetails>> resultSort;
//根据开始日期排序, groupBy字段分组返回类型修改为LinkedHashMap,否则乱序
resultSort = result
        .stream()
        .sorted(Comparator.comparing(ProcessDetails::getBeginTime))
        .collect(Collectors.groupingBy(ProcessDetails::getGroupBy,LinkedHashMap::new,Collectors.toList()));

以上就是Collectors.groupingBy分组后乱序问题的全部内容

相关文章
|
Arthas Java 测试技术
Docker 环境中 Spring Boot 应用的 Arthas 故障排查与性能优化实战
Docker 环境中 Spring Boot 应用的 Arthas 故障排查与性能优化实战
|
分布式计算 Java Linux
Java 生成 UUID
Java 生成 UUID
11192 1
|
8月前
|
JSON 前端开发 Java
深入理解 Spring Boot 中日期时间格式化:@DateTimeFormat 与 @JsonFormat 完整实践
在 Spring Boot 开发中,日期时间格式化是前后端交互的常见痛点。本文详细解析了 **@DateTimeFormat** 和 **@JsonFormat** 两个注解的用法,分别用于将前端传入的字符串解析为 Java 时间对象,以及将时间对象序列化为指定格式返回给前端。通过完整示例代码,展示了从数据接收、业务处理到结果返回的全流程,并总结了解决时区问题和全局配置的最佳实践,助你高效处理日期时间需求。
1015 0
|
消息中间件 存储 安全
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
513 0
|
缓存 NoSQL Java
什么是缓存?如何在 Spring Boot 中使用缓存框架
什么是缓存?如何在 Spring Boot 中使用缓存框架
795 0
|
UED
使echarts图例legend只选中一个(selectedMode)
本文介绍了如何在ECharts图表中设置图例(legend)的选中模式为单选('single'),以确保在有多个图例时,用户只能选择一个图例项进行展示,从而提升图表的可读性和用户体验。
1470 1
使echarts图例legend只选中一个(selectedMode)
|
SQL Java 数据库连接
MyBatis SQL 批量更新(代码➕案例)
MyBatis SQL 批量更新(代码➕案例)
1382 0
|
Oracle NoSQL 关系型数据库
实时计算 Flink版操作报错合集之报错ClassCastException异常如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
514 0
命令行下使用javac编译文件时出现 错误: 编码 GBK 的不可映射字符
命令行下使用javac编译文件时出现 错误: 编码 GBK 的不可映射字符
516 0
|
消息中间件 Kafka API
【Kafka】kafka 如何不消费重复数据?
【4月更文挑战第7天】【Kafka】kafka 如何不消费重复数据?