Java Stream流式运算用得很熟练？来看看anyMatch、allMatch、noneMatch都有哪些坑点

xiaoyi

发布于 2024-04-10 16:11:54

2200

发布于 2024-04-10 16:11:54

文章被收录于专栏：小义思小义思

在Java 8中，Stream API的引入为数据处理带来了革命性的变化。它不仅简化了集合操作，还提高了代码的可读性和性能。然而，在使用Stream API的anyMatch、allMatch和noneMatch这三个方法时，一不小心就有可能会遇到一些意想不到的问题。

AnyMatch 任何一个满足？

anyMatch方法用于判断流中是否存在至少一个元素满足给定的谓词。当流为空时，anyMatch会返回false，这是因为anyMatch期望流中至少有一个元素来进行判断。

另外，anyMatch在找到第一个满足条件的元素后就会停止检查。这意味着，即使流中有更多的元素满足条件，anyMatch也不会进一步检查。这种行为在并行流中尤为明显，因为并行流的元素处理是并发的，可能会影响结果的准确性。

来看一段并行流中使用anyMatch的代码：

import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.IntStream;

public class ParallelStreamAnyMatchExample {
    public static void main(String[] args) {
        // 创建一个原子整数用于计数
        AtomicInteger count = new AtomicInteger(0);

        // 创建一个包含100个随机数的流
        IntStream numbers = IntStream.iterate(0, n -> n + 1).limit(100).parallel();

        // 使用并行流和anyMatch检查是否有任何数大于50
        boolean hasNumberGreaterThan50 = numbers.anyMatch(number -> {
            // 增加计数器的值
            count.incrementAndGet();
            return number > 50;
        });

        // 打印结果
        System.out.println("Has a number greater than 50: " + hasNumberGreaterThan50);// true
        System.out.println("Number of increments to count: " + count.get());// 16
    }
}

在这个例子中创建了一个原子整数count，用于计数。并行流numbers包含从0开始的连续整数，限制为100个元素。然后使用anyMatch方法来检查流中是否有任何数大于50。

anyMatch方法的短路特性意味着一旦找到第一个大于50的数，它就会立即返回true，并且不再评估流中的其他元素。因此，count的增加次数可能少于流中实际大于50的元素数量，不能确定count的最终值，这导致了不确定性。

而且由于anyMatch在并行流中的操作是并发执行的，不同的线程可能会同时尝试增加count的值，这可能导致竞态条件。在实际应用中，需要确保这些操作是线程安全的。

所有元素都满足条件？allMatch的误区

allMatch方法看起来和anyMatch类似，但它用于判断流中的所有元素是否都满足给定的谓词。如果所有元素都满足条件，allMatch返回true；否则返回false。

一个常见的误区是认为allMatch在流为空时会返回false。实际上，这是错误的。因为如果流为空，没有元素需要检查，所以可以认为所有条件都已满足。这一点在处理空集合时尤其重要，因为错误的假设可能导致逻辑错误。

像下面这一段代码的打印结果就是true。

HashMap<String, String> map = Maps.newHashMap();
boolean b1 = map.entrySet().stream().allMatch(item -> item.equals("1"));
System.out.println(b1);//true

源码Stream类中也明确说明集合list的size为0时，allMatch总会返回true。