嵌套Lambda表达式问题：无法向外部List变量添加元素求助

你的代码存在两个核心问题：

1. 变量引用不可修改：Lambda表达式内部不允许修改外部变量的引用（outputLines = ...属于重新赋值，改变了变量指向的对象），外部变量必须是final或等效final的。
2. 并发安全问题：ArrayList不是线程安全集合，在并行流中直接操作会导致数据竞争，出现元素丢失或异常。

方案1：保留forEach逻辑的修正实现 #

把ArrayList替换为线程安全的CopyOnWriteArrayList，通过addAll批量添加匹配行，避免修改变量引用：

public List<String> searchForText(List<Path> inputFiles, String SEARCH_TOKEN) {
    List<String> outputLines = new CopyOnWriteArrayList<>();
    inputFiles.parallelStream().forEach(path -> {
        try (Stream<String> lines = Files.lines(path)) {
            List<String> matchedLines = lines.filter(a -> a.trim().contains(SEARCH_TOKEN))
                                            .collect(Collectors.toList());
            outputLines.addAll(matchedLines);
        } catch (IOException e) {
            e.printStackTrace();
        }
    });
    return outputLines;
}

方案2：更符合流API风格的推荐实现 #

放弃forEach，改用flatMap合并所有文件的行流，统一过滤收集，由流框架自动处理并行与线程安全，代码更简洁高效：

public List<String> searchForText(List<Path> inputFiles, String SEARCH_TOKEN) {
    return inputFiles.parallelStream()
            .flatMap(path -> {
                try {
                    return Files.lines(path);
                } catch (IOException e) {
                    e.printStackTrace();
                    return Stream.empty();
                }
            })
            .filter(line -> line.trim().contains(SEARCH_TOKEN))
            .collect(Collectors.toList());
}

关键说明 #

• 方案1严格保留了你要求的inputFiles.parallelStream()和逐行读取逻辑，通过线程安全集合解决并发问题，同时规避了变量引用修改的编译错误。
• 方案2是流API的标准用法，利用flatMap将多文件的行流合并，流程清晰且无需手动处理线程安全，性能更优。

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