Kotlin流处理代码执行机制及避免中间集合方案咨询

嘿，咱们把这个问题掰碎了说清楚：

原代码的执行行为 #

你的这段代码会创建包含5000000个整数的临时集合，原因很直白：

• 1..10_000_000是一个IntRange，属于普通的Iterable类型
• 对于普通Iterable的filter方法，Kotlin采用的是贪婪执行（eager execution）：它会遍历整个范围，把所有符合it % 2 == 1的奇数全部收集到一个新的List里——哪怕你在forEach里只处理了11个元素就return终止，这500万元素的临时集合也已经提前生成了，完全是没必要的内存浪费。

如何避免生成中间集合？ #

要实现“filter结果直接传递给forEach，仅处理必要元素”的效果，你需要把普通的Iterable转换成Sequence（序列）。Sequence的操作是**延迟执行（lazy execution）**的，只有触发终端操作（比如forEach）时才会逐个处理元素，不会提前生成中间集合。

修改后的代码如下：

class Tests {
    @Test
    fun test() {
        var counter = 0
        (1..10_000_000).asSequence() // 关键一步：转换成Sequence，开启延迟执行
            .filter { it % 2 == 1 }
            .forEach {
                counter++
                if (counter > 10) return
            }
    }
}

修改后的执行流程 #

当调用forEach这个终端操作时，整个序列才会开始工作：

1. 从范围里取出第一个元素1，经过filter检查是奇数，进入forEach，counter变为1
2. 取出2，filter检查不通过，直接跳过
3. 取出3，filter通过，counter变为2
4. ……以此类推，直到counter增加到11时，return终止整个过程

整个过程中不会生成任何包含大量元素的中间集合，只会逐个处理元素，满足终止条件就立刻停下，内存占用可以忽略不计。

额外小提示 #

• 区分贪婪操作和延迟操作：对于Iterable，filter、map等操作会返回新集合，属于贪婪执行；对于Sequence，这些操作会返回新的Sequence，属于延迟执行，不会立即处理元素。
• 终端操作（比如forEach、count、toList）是触发Sequence执行的关键，只有调用终端操作时，所有之前的延迟操作才会逐个执行。

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