如何将集合划分为任意大小的分区

Question

我尝试使用Java8Lambda表达式和流来解析一些日志。我有一个巨大的日志文件，运行了一次又一次。我想把它分成不同的集合，每次运行一个集合。我不知道日志在advanced中运行了多少次。为了锻炼我非常虚弱的lambda肌肉，我想在列表中一次完成。

这是我目前的实现：

    List<String> lines = readLines(fileDirectory);

    Pattern runStartPattern = Pattern.compile("INFO: \\d\\d:\\d\\d:\\d\\d: Starting");

    LinkedList<List<String>> testRuns = new LinkedList<>();

    List<String> currentTestRun = new LinkedList<>(); // In case log starts in middle of run
    testRuns.add(currentTestRun);

    for(String line:lines){
        if(runStartPattern.matcher(line).find()){
            currentTestRun = new ArrayList<>();
            testRuns.add(currentTestRun);
        }
        currentTestRun.add(line);
    }
    if(testRuns.getFirst().size()==0){ // In case log starts at a run
        testRuns.removeFirst();
    }

这里基本上类似于TomekRekawek的解决方案，但首先是未知的分区大小。

Answer 1

没有标准方法可以轻松在流API中实现这一点，但我的StreamX库有一个groupRuns方法，可以非常轻松地解决这一问题：

List<List<String>> testLines = StreamEx.of(lines)
        .groupRuns((a, b) -> !runStartPattern.matcher(b).find())
        .toList();

它根据应用于一对相邻元素的谓词对输入元素进行分组。在这里，如果第二行与runStartPattern匹配，我们不想对行进行分组。无论日志是否在运行过程中开始，都可以正常工作。同样，这个特性也适用于并行流。