Java中如何在Stream.forEach执行完成前提前终止遍历？

Java 8 Stream 的forEach本身不支持直接中断遍历，lambda 内部的普通 return 只会跳过当前元素处理，且默认不允许抛出IOException这类受检异常，你可以选择以下两种常用方案实现需求：

方案1：包装受检异常为运行时异常抛出 #

这是最简单的实现方式，利用异常穿透直接终止整个 Stream 遍历，用JDK自带的UncheckedIOException做包装即可，不需要自定义异常：

try (Stream<Path> filePathStream = Files.walk(Paths.get(logs))) {
    filePathStream.forEach(filePath -> {
        if (Files.isRegularFile(filePath)) {
            try {
                processLog(filePath.toFile());
            } catch (IOException e) {
                // 抛出非受检异常直接终止遍历
                throw new UncheckedIOException(e);
            }
        }
    });
} catch (UncheckedIOException e) {
    // 在此处处理processLog抛出的原始IO异常
    IOException originalException = e.getCause();
    // 你的异常处理逻辑
} catch (IOException e) {
    // 处理Files.walk方法本身可能抛出的IO异常
}

方案2：转为迭代器手动控制遍历 #

如果你不想用异常控制流程（符合大多数编码规范的要求），可以把Stream转为迭代器遍历，遇到异常直接break即可：

try (Stream<Path> filePathStream = Files.walk(Paths.get(logs))) {
    Iterator<Path> pathIterator = filePathStream.iterator();
    while (pathIterator.hasNext()) {
        Path filePath = pathIterator.next();
        if (Files.isRegularFile(filePath)) {
            try {
                processLog(filePath.toFile());
            } catch (IOException e) {
                // 直接跳出循环终止遍历
                // 你的异常处理逻辑
                break;
            }
        }
    }
} catch (IOException e) {
    // 处理Files.walk方法本身可能抛出的IO异常
}

两种方案都可以立刻终止遍历，不会继续处理后续的文件，且try-with-resources会自动关闭Stream资源，不会出现泄漏问题。

内容的提问来源于stack exchange，提问作者Guy