使用方法体的 Java 8 谓词只被调用一次？

Question

我检查了以下片段：public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {    Map<Object, Boolean> computed = new ConcurrentHashMap<>();/*IS THIS LINE CALLED ONCE ON STREAM->FILTER NOT MATTER HOW LONG THE STREAM IS*/    return t -> {return computed.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;};}private void test(){    final long d = Stream.of("JOHN","STEPHEN","ORTIZ","RONDON")            .filter(distinctByKey(Function.identity()))            .count();    System.out.println("d = " + d);}这段代码不是我的。我知道在这个例子中使用 aConcurrentMap不是正确的选择，在这种情况下我应该使用ConcurrentMap而不是Map，但这不是我现在关心的问题。我认为distinctByKey在每次迭代中调用或解释该方法Stream。我的意思Map是在每一轮都被实例化，但事实并非如此！方法体Predicate只调用一次吗？在Stream迭代中，这是一个断言吗？因为当我尝试以下代码时：final Function<String,Integer>a = (name)->name.length();System.out.println(distinctByKey(a).test("JOHN"));System.out.println(distinctByKey(a).test("STEPHEN"));System.out.println(distinctByKey(a).test("ORTIZ"));System.out.println(distinctByKey(a).test("RONDON"));我可以看到方法的主体确实在每一行中都被调用了。是什么让过滤器的主体只被调用一次？

Answer 1

当您调用.filter(distinctByKey(Function.identity()))时，传递给的参数会filter()被评估。那是唯一一次distinctByKey(Function.identity())执行并返回Predicate<String>.

然后对其进行多次评估（即执行Predicate它的test()方法），每次针对Stream.

为了使您的最后一个代码段的行为类似于Stream管道，它应该如下所示：

final Function<String,Integer> a = (name)->name.length();

Predicate<String> pred = distinctByKey(a);

System.out.println(pred.test("JOHN"));

System.out.println(pred.test("STEPHEN"));

System.out.println(pred.test("ORTIZ"));

System.out.println(pred.test("RONDON"));

Answer 2

distinctByKey返回缓存 的单个实例。例如，如果将通过 lambda 的创建替换为匿名内部类，则可以获得几乎相同的结果。PredicateConcurrentHashMapPredicate




Answer 3

我认为 distinctByKey 方法在 Stream 的每次迭代中被调用或解释，我的意思是 Map 在每个回合中都是实例，但事实并非如此！我的问题是 Predicate 方法的主体只调用一次？在 Stream 迭代中，这是一个断言吗？

不。Streams 不是魔法，它们不会推翻标准的 Java 语义。考虑提供的代码：

    final long d = Stream.of("JOHN","STEPHEN","ORTIZ","RONDON")

            .filter(distinctByKey(Function.identity()))

            .count();

从图片中取出特定类型和方法，具有以下一般形式：

long x = A.b(y).c(z).d(w);

没有理由期望 、 或 中的任何一个a()在b()该c()链中被多次调用，或者它们的参数每个都被计算多次。这不受某些类型的影响Stream。

相反，在您的情况下，您的方法Predicate返回的（唯一调用）在处理嵌入它的流时被多次使用。它包含对 a 的引用，它在执行其工作时使用和修改它。distinctByKey()PredicateMap