kotlin - 使用 Kotlin Channel 是什么意思？

Question

Kotlin 文档使用术语 consume 来描述诸如 Channel#first() 之类的方法的行为以及诸如 Channel 之类的方法的名称#consumeEach().

我很难理解 channel 消费与非消费的含义。

非消费到底是什么样的？

Channel API 是否允许在不消费的情况下访问 channel 中的项目？

除了consumeEach()，消费是否总是意味着完全清空一个 channel ？

Answer 1

以下代码的输出说明了“消费”的含义以及consumeEach的效果。

fun f1() = runBlocking {
    val numbers = produce {
        repeat(5) {
            send(it)
            delay(100)
        }
    }
    run {
        for (i in numbers) {
            trace(i)
            if (i == 2) return@run
        }
    }
    trace("after run")
    for (i in numbers) {
        trace(i)
    }
    trace("exiting f1")
}
f1()

println()

fun f2() = runBlocking {
    val numbers = produce {
        repeat(5) {
            send(it)
            delay(100)
        }
    }
    run {
        numbers.consumeEach {
            trace(it)
            if (it == 2) return@run
        }
    }
    trace("after run")
    for (i in numbers) {
        trace(i)
    }
    trace("exiting f2")
}
f2()

输出:

[main @coroutine#1]: 0
[main @coroutine#1]: 1
[main @coroutine#1]: 2
[main @coroutine#1]: after run
[main @coroutine#1]: 3
[main @coroutine#1]: 4
[main @coroutine#1]: exiting f1

[main @coroutine#3]: 0
[main @coroutine#3]: 1
[main @coroutine#3]: 2
[main @coroutine#3]: after run
[main @coroutine#3]: exiting f2

我们看到(在 f1 中)我们可以停止迭代一个 channel ，然后从我们停止的地方继续。但是，当使用 consumeEach(在 f2 中)时，我们无法停止并继续，即使 channel 最初能够产生大于 2 的数字也是如此。