当Kotlin通道变满时执行一段代码

import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

fun main() = runBlocking {
    val channel = Channel<Int>(capacity = 5) // 创建一个容量为5的通道

    // 启动一个协程来向通道中发送数据
    launch {
        repeat(10) {
            if (!channel.offer(it)) {
                // 当通道已满时执行一段代码
                println("通道已满，执行相应的操作")
            }
        }
        channel.close() // 关闭通道
    }

    // 从通道中接收数据
    for (element in channel) {
        println("接收到数据：$element")
    }
}