java - 流<流> : flatMap vs. 减少-6ren

java - 流<流> : flatMap vs. 减少

转载作者：塔克拉玛干更新时间：2023-11-03 03:54:19

28

4

<分区>

如果我执行以下“连接”两个流的代码

首先通过 flatMapping a Stream<Stream<Integer>>
然后通过减少 Stream<Stream<Integer>>使用 Stream.concat()

我在这两种情况下都获得了相同的正确结果，但过滤操作的次数不同。

public class FlatMapVsReduce {
    public static void main(String[] args) {
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9);

        Predicate<Integer> predicate1 = i -> {
            System.out.println("testing first condition with " + i);
            return i == 3;
        };

        Predicate<Integer> predicate2 = i -> {
            System.out.println("testing second condition with " + i);
            return i == 7;
        };

        System.out.println("Testing with flatMap");
        Integer result1 =
            Stream.of(list.stream().filter(predicate1),
                      list.stream().filter(predicate2))
                  .flatMap(Function.identity())
                  .peek(i -> System.out.println("peeking " + i))
                  .findFirst()
                  .orElse(null);
        System.out.println("result1 = " + result1);

        System.out.println();
        System.out.println("Testing with reduce");
        Integer result2 =
            Stream.of(list.stream().filter(predicate1),
                      list.stream().filter(predicate2))
                  .reduce(Stream::concat)
                  .orElseGet(Stream::empty)
                  .peek(i -> System.out.println("peeking " + i))
                  .findFirst()
                  .orElse(null);
        System.out.println("result2 = " + result2);
    }
}

我在两种情况下都得到了预期的结果 (3)。但是，第一个操作对集合中的每个元素应用第一个过滤器，而第二个操作在满足一个元素后立即停止。输出是:

Testing with flatMap
testing first condition with 1
testing first condition with 2
testing first condition with 3
peeking 3
testing first condition with 4
testing first condition with 5
testing first condition with 6
testing first condition with 7
testing first condition with 8
testing first condition with 9
result1 = 3

Testing with reduce
testing first condition with 1
testing first condition with 2
testing first condition with 3
peeking 3
result2 = 3

为什么两者之间存在行为差异？是否可以改进 JDK 代码以使其在第一种情况下与在第二种情况下一样高效，或者 flatMap 中是否有某些东西使其不可能？

附录:以下替代方案与使用 reduce 的替代方案一样高效，但我仍然无法解释原因:

    Integer result3 = Stream.of(predicate1, predicate2)
                            .flatMap(c -> list.stream().filter(c).limit(1))
                            .peek(i -> System.out.println("peeking " + i))
                            .findFirst()
                            .orElse(null);
    System.out.println("result3 = " + result3);

28

4

0

文章推荐： java - 使用java将Ms word表格的单元格转换为图像

Java 8 FlatMap - 在嵌套表单中添加项目并使用 FlatMap 检索对象
我有一个对象Foo，其中包含Bar列表。这些类的描述如下: class Foo { String name; List bars = new ArrayList(); Foo(
Javascript - 数组上的 flatMap 方法 - (flatMap 不是函数)
根据 Mozilla 开发者网站: flatMap() 方法首先使用映射函数映射每个元素，然后将结果展平到一个新数组中。它与 map 后跟深度为 1 的 flat 相同，但 flatMap 通常非常有
scala - flatMap(func) 与 flatMap(func(_))
我对无法找到该问题的现有问题感到非常惊讶。这是为什么，鉴于: val p: Int => Option[Int] = Some(_) List(1, 2, 3).flatMap(p) 我得到: :14
java - Optional.flatMap() 和 Stream.flatMap() 之间有什么区别
关闭。此题需要details or clarity 。目前不接受答案。想要改进这个问题吗？通过 editing this post 添加详细信息并澄清问题. 已关闭 5 年前。 Improve th
java - 在 map().flatMap() 上使用单个 flatMap() 是否更好？
我想知道两种平面映射情况之间是否存在显着差异。案例 1: someCollection .stream() .map(CollectionElement::getAnotherCol
scala - 为什么 scala.util.Success.flatMap (Try.flatMap) 在应用其参数后再次使用 try-catch ？
以下是flatMap的定义取自 scala.util.Success。 final case class Success[+T](value: T) extends Try[T] { def fl
python - 相当于Python中的pySpark flatMap
我正在寻找一个函数来展平列表数组。首先，我在 RDD 系统上使用 Apach Spark 函数 flatMap 实现了我的解决方案，但我想在本地执行此操作。但是，我无法找到的等价物 samples
scala - flatMap 忽略结果
我想知道是否存在忽略 flatMap 中的结果的函数(在 scala 或 cat 中) .例如。 Some("ignore this").ignoreArgumentFlatMap(Some("res
scala flatMap 展平嵌套列表
我正在学习 Scala 并解决了 99 个 Scala 问题。对于以下练习: 展平嵌套列表结构。示例: scala> flatten(List(List(1, 1), 2, List(3, List(
Swift flatMap 链展开
当编译器进入无限循环时，是否有人遇到过使用此类 flatMap 链(或什至更长)的问题。 let what = Future.init { (promise) in promise(.succ
scala - 实现列表#flatMap
有没有更好的函数方式来写 flatMap ? def flatMap[A,B](list: List[A])(f: A => List[B]): List[B] = list.map(x =>
java - 如何懒惰地评估嵌套的 flatMap
我试图从两个中变出笛卡尔积潜在无限然后我通过 limit() 限制的流. 到目前为止，这(大约)是我的策略: @Test void flatMapIsLazy() { Stream.
Scala:带元组的 flatMap
为什么以下声明对 .map() 有效但不适用于 .flatMap() ? val tupled = input.map(x => (x*2, x*3)) //Compilation error:
haskell - flatmap 列表和可能
我正在寻找可以同时映射和展平 Lists 和 Maybes 的代码。我在 this topic 中发现了这样一个 flatMap 函数: flatMap :: (t -> [a]) -> [t] ->
Scala - Flatmap 一系列选项和可遍历
考虑在某些大小写匹配上编写的 flatMap。例如: list.flatMap( v => v match { case Cond1 => if(something) Some
kotlin - FlatMapping ListK和Option
我无法使用ListKOf平面映射T -> Option。例如 listOf(1,2,3).k().flatMap { i -> if (i % 2 == 0) Some(i) else None
kotlin - 带有toList的RxJava flatMap
有人可以解释我如何在RxJava中通过flatMap运算符传递onComplete信号吗？如果对flatMap运算符进行注释，则可以获取1到10的数字列表，这意味着toList将收到onComple
kotlin - flatmap 键列表和集合到对列表中
我正在做一个在线类(class)并误读了一个问题(这就是为什么我认为可以发布这个问题，因为答案与类(class)中的问题无关!)。 data class Trip( val drive
Kotlin flatmap 解压数据类列表
给定作为数据类的二维坐标列表 data class Point(val x: Int, val y:Int) val points: List 和 TornadoFX(Kotlin 中的 JavaFX
java - flatMap 需要不必要的转换
这个问题已经有答案了: What is the difference between .stream() and Stream.of? (5 个回答) 已关闭 3 年前。我有以下代码: List p

首页

博学

6Ren·AI

商城

java - 流<流> : flatMap vs. 减少