Kotlin 流缓冲容量

Question

我有一个关于 Kotlin 流缓冲容量的问题。以下代码:

import kotlinx.coroutines.flow.*

suspend fun main() = coroutineScope {
    flow { 
        for (i in 1..3) { 
            println("Emiting $i")
            emit(i) 
        }
    }.buffer(0)
    .collect { 
        value -> 
            delay(100)
            println("Consuming $value")
    }
}

生成以下输出:

Emiting 1
Emiting 2
Consuming 1
Emiting 3
Consuming 2
Consuming 3

如果我删除缓冲区，结果是:

Emiting 1
Consuming 1
Emiting 2
Consuming 2
Emiting 3
Consuming 3

我应该假设当容量为 0 时意味着实际上是 1 吗？

Answer 1

不，容量实际上是 0。看起来你正在缓冲一个元素，因为收集首先消耗一个元素，然后延迟 100 毫秒。这允许流同时发出另一个元素。buffer函数实际上创建了第二个协程，允许 flow和 collect并发执行的函数。无需调用 buffer ，每个元素必须用 collect 完成之前 flow可以继续下一个元素，因为两个函数都由同一个协程执行。
让我们逐步查看您的代码以了解它是如何发生的:

流延迟 1 毫秒，打印 Emitting 1 , 发出 1 ，并暂停。

收藏即刻消费1 ，然后开始延迟 100 毫秒。

流程继续，因为 1已消耗，再延迟 1 毫秒，打印 Emitting 2 , 发出 2 ，然后暂停。

收集完成100ms的延迟，打印Consuming 1 ，然后消耗 2并再延迟 100 毫秒。

流程继续，因为 2已消耗，再延迟 1 毫秒，打印 Emitting 3 , 发出 3 ，然后暂停。

收集完成100ms的延迟，打印Consuming 2 ，然后消耗 3并再延迟 100 毫秒。

收集完成100ms的延迟，打印Consuming 3 ，然后完成收集。

流程继续并结束，因为没有更多元素要发出。

您可以阅读更多关于 buffer 的信息这里: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/buffer.html