如何判断发送操作时通道已关闭？解决send永久挂起问题

你提供的代码里，channel.send(0)会永久挂起——子协程关闭通道后，send会一直等待接收方，但通道已经关闭且没有接收者，导致发送操作永远无法完成。

要实现“发送失败时抛出异常或直接返回”的需求，推荐使用Kotlin协程内置的sendCatching()方法，它是send()的替代方案，不会永久挂起，而是返回一个ChannelResult对象来表示发送结果：

修改后的示例代码 #

suspend fun main() = coroutineScope {
    val channel = Channel<Int>()
    
    launch {
        println("closing")
        channel.close()
    }
    
    val sendResult = channel.sendCatching(0)
    if (sendResult.isFailure) {
        println("发送失败: ${sendResult.exceptionOrNull()}")
    }
    println("end")
}

关键说明 #

• sendCatching()尝试发送元素时，若通道已关闭、被取消，或无法找到接收方，会立即返回失败的ChannelResult
• 可以通过isFailure判断发送是否失败，通过exceptionOrNull()获取具体失败原因（通常是ClosedSendChannelException）
• 若希望失败时直接抛出异常，可调用getOrThrow()方法：

  channel.sendCatching(0).getOrThrow()
  

自定义封装（可选） #

如果需要更贴合原有send()的调用体验，可以封装一个工具函数：

suspend fun <E> SendChannel<E>.sendOrThrow(element: E) {
    sendCatching(element).getOrThrow()
}

// 使用方式
channel.sendOrThrow(0)

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