关闭后忽略对协作频道的提供

通道引发此异常 by design 作为正确沟通的手段。

如果您绝对必须具有类似的功能,那么可以使用此类扩展函数:

private suspend fun <E> Channel<E>.sendOrNothing(e: E) {
    try {
        this.send(e)
    }
    catch (closedException: ClosedSendChannelException) {
        println("It's fine")
    }
}

您可以使用以下代码对其进行测试:

val channel = Channel<Int>(capacity = 3)
    launch {

        try {
            for (i in 1..10) {
                channel.sendOrNothing(i)
                delay(50)
                if (i == 5) {
                    channel.close()
                }
            }

            println("Done")
        }
        catch (e: Exception) {
            e.printStackTrace()
        }
        finally {
            println("Finally")
        }
    }

    launch {
        for (c in channel) {
            println(c)
            delay(300)
        }
    }

正如您将注意到的,由于频道关闭,制作人将开始打印“它很好”,但消费者仍然可以读取前5个值。

关于第二个问题:视情况而定。

通道没有这么大的开销,也没有悬挂的协程器。但你知道,泄漏就是泄漏。

我最后发了邮件 an issue 对于回购,解决方案是 BroadcastChannel . 您可以创建一个新的 ReceiveChannel 通过 openSubscription ,关闭时不会关闭 SendChannel .

这更准确地反映了RxJava的 PublishSubject