java-stream 相关问题

使用此标记可以获得与使用Stream API相关的问题。它是在Java 8中引入的,支持对值流进行功能样式的操作,例如集合上的filter-map-reduce管道。

java中parallelStream的错误

有人可以告诉我为什么会发生这种情况以及这是预期的行为还是错误 List a = Arrays.asList(1,1,3,3); a.parallelStream().filter(Objects::nonNull) .过滤器(值...

回答 1 投票 0

同一对象在并行流中被处理多次

我有以下逻辑,尝试将文件列表(SmbFile)上传到AWS S3。 对于每个文件,它将检查是否已上传,如果尚未上传,则上传。 // 上传批处理...

回答 1 投票 0

Java 8 List<V> 到 Map<K, V>

我想使用 Java 8 的流和 lambda 将对象列表转换为映射。 这就是我在 Java 7 及以下版本中的编写方式: 私有地图 nameMap(List c...

回答 23 投票 0

Java 的 Stream.distinct() 如何选择要使用的重复项

在 Java 中,假设我有一个名为 Person 的类。它有四个属性: 长人物ID 字符串名称 年龄 列表 宠物名字 假设我有一个名为 peop 的人的数组列表变量...

回答 2 投票 0

创建重复计数映射后如何优化此重复查找代码

给定 ['A','a','B','C','C'] 的 ArrayList,则重复项为 ['A','a','C','C'] 和非重复项是['B']。 我试过 : Map 计数 = nums.parallelStream() .collect( Collectors.groupingBy( ...

回答 2 投票 0

替换字符串列表中第一个分隔符之前的部分字符串

我有一个字符串列表: 列表 = {"100:250:33","100:234:590","100:250:3400".........n} 我想用另一个字符串替换此列表中所有字符串的第一部分...

回答 1 投票 0

使用 Java Flux 发生异常时返回之前的成功响应

有人可以指导我吗,因为我是新的变化并试图了解如何处理这种情况? 问题:我在 getResp() 方法的通量响应之一中遇到 readTimeout 异常

回答 1 投票 0

Java Flux 异常处理?

有人可以指导我吗,因为我是新的变化并试图了解如何处理这种情况? 问题:我在 getResp() 方法的通量响应之一中遇到 readTimeout 异常

回答 1 投票 0

使用 Stream API 将谓词链接为一个谓词

我有一个谓词列表(List>),我想将其链接到一个 using 或方法中。我如何使用 Stream API 来实现这一目标?

回答 1 投票 0

Java 8 比较整数列表和对象列表

我已输入 ID 列表 idList = List.of(100, 101, 102, 103, 104); 从数据库我得到了对象列表 @盖特 @Builder 公共类自定义对象{ 私有 int id; } 列表 我已输入 Ids List<Integer> idList = List.of(100, 101, 102, 103, 104); 从数据库我得到了对象列表 @Getter @Builder public class CustomObject { private int id; } List<CustomObject> fromDB = List.of( CustomObject.builder().id(102).build(), CustomObject.builder().id(104).build() ); 我想查看输入 ID 与 DB CustomObject 列表响应之间的差异 如果数据库的响应不包含输入的 id,我想看到这个差异 List<Integer> listOfID = fromDB.stream().map(CustomObject::getId).toList(); String list = idList.stream() .filter(element -> !listOfID.contains(element)) .map(String::valueOf) .collect(Collectors.joining(", ")); System.out.println("RESULT: " + list); RESULT: 100, 101, 103 我在 Stream API 方面没有丰富的经验,是否可以简化我的实现? 我会将列表 fromDB 转换为一组 ID,然后将其从 idList 中删除以获得差异: Set<Integer> fromDBIntegers = fromDB.stream().map(CustomObject::getId).collect(Collectors.toSet()); String difference = idList.stream() .filter(id -> !fromDBIntegers.contains(id)) .map(String::valueOf) .collect(Collectors.joining(", "));

回答 1 投票 0

java中的SpinedBuffer是什么以及它是如何工作的?

在Java Stream API实现中,他们使用一种称为SpinedBuffer的数据结构,在java Doc中他们将其描述如下: 一个或多个数组用于存储元素。使用多个

回答 1 投票 0

如何逐个元素组合多个集合(队列或列表)?

我有 3 个记录队列(大小和日期时间顺序相同),想要逐条记录地组合它们。 它类似于下面的内容: 记录BuyOrder(字符串日期,字符串产品,双buyPx){}; 重新...

回答 1 投票 0

如何在Java中的parallelStream调用中同步一个方法?

我想同步functionB。我的意思是,当某个 Attribute 对象调用 functionA 时,总是同时运行对象的 functionB 之一。但是每个对象中的 functionC 和 functionD...

回答 1 投票 0

Java中parallelStream调用时如何同步一个方法?

我想要同步功能B。我的意思是,当某些 Attriute 对象调用 functionA 时,总是同时运行对象的 functionB 之一。但是每个对象c中的functionC和functionD...

回答 1 投票 0

使用parallelStream时Spring SecurityContext不可用

我有以下代码块: myList.parallelStream().forEach(item -> { //此外部 api 调用将使用当前 //spring security 用值填充标头 //那就是

回答 1 投票 0

并行流和 SpringSecurity

我有以下代码块: myList.parallelStream().forEach(item -> { //此外部 api 调用将使用当前 //spring security 用值填充标头 //那就是

回答 1 投票 0

Java 8 Streams API 按两个字段分组并返回更新后的集合

我有java自定义类,即具有以下字段的员工, 公共类员工{ 私有字符串名称; 私人字符串部门; 私有整数年龄; 私人双薪; } 公开

回答 1 投票 0

并行 for 循环内的嵌套 for 循环会给出不正确的结果

我正在使用parallelStream 迭代foreach 循环,但在内部我有一个嵌套for 循环列表。 在迭代过程中,每次都会给出不同值的错误结果。 我真的需要这个

回答 1 投票 0

转换映射:向现有映射添加新的键值对 Java 8

我正在尝试通过添加新的 JsonObject 键值对来转换 Map,如果地图的任何 JsonObject 的键包含“-fragment”字符串。 设置&...

回答 1 投票 0

如何从for循环转换为“过滤器”[关闭]

我有一个简单的for循环 我想使用过滤器将其更改为语句 for (int lotto_num: 乐透) { 如果(lotto_num == 0){ 未知_计数++; } 对于 (int win_num : 赢...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.