编辑“︁Kotlin协程间通信”︁（章节）

== Channel（通道） ==
Channel是Kotlin协程间通信的核心机制之一，它类似于阻塞队列，但完全非阻塞且协程友好。Channel可以在发送（`send`）和接收（`receive`）操作时挂起协程，直到数据可用。

=== 基本用法 ===
以下是一个简单的Channel示例：

<syntaxhighlight lang="kotlin">
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*

fun main() = runBlocking {
    val channel = Channel<Int>() // 创建一个Int类型的Channel

    launch { // 启动发送协程
        for (i in 1..5) {
            println("发送 $i")
            channel.send(i) // 发送数据
            delay(100) // 模拟延迟
        }
        channel.close() // 关闭Channel
    }

    launch { // 启动接收协程
        for (value in channel) { // 接收数据
            println("接收 $value")
        }
        println("Channel已关闭")
    }
}
</syntaxhighlight>

'''输出：'''
<pre>
发送 1
接收 1
发送 2
接收 2
发送 3
接收 3
发送 4
接收 4
发送 5
接收 5
Channel已关闭
</pre>

=== Channel的类型 ===
Kotlin提供了几种不同类型的Channel：
* '''RendezvousChannel'''（默认）：发送和接收必须同时发生，否则挂起。
* '''BufferedChannel'''：允许缓存一定数量的元素。
* '''ConflatedChannel'''：只保留最新的元素，丢弃旧值。
* '''UnlimitedChannel'''：无限制缓存（可能导致内存问题）。

=== 实际案例：生产者-消费者模型 ===
Channel常用于生产者-消费者场景。例如，一个协程生成数据，另一个协程处理数据：

<syntaxhighlight lang="kotlin">
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*

fun main() = runBlocking {
    val dataChannel = Channel<String>()

    // 生产者
    launch {
        val data = listOf("数据1", "数据2", "数据3", "数据4")
        data.forEach {
            dataChannel.send(it)
            delay(200)
        }
        dataChannel.close()
    }

    // 消费者
    launch {
        for (item in dataChannel) {
            println("处理: $item")
            delay(300) // 模拟处理时间
        }
        println("处理完成")
    }
}
</syntaxhighlight>