面试题：Kotlin中Channel在协程通信里的基本用法

Question

请简述Kotlin中Channel的基本概念，并举例说明如何使用Channel在两个协程之间进行简单的数据传递。

Answer 1

Kotlin中Channel的基本概念

在Kotlin中，Channel 是一种用于在协程之间进行异步通信的数据结构，它遵循生产者 - 消费者模型。Channel 允许一个协程（生产者）发送数据，另一个或多个协程（消费者）接收数据，以此实现协程间的数据传递和同步。Channel 提供了线程安全的队列操作，其容量可以是有限的或无限的。

示例代码实现简单的数据传递

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel

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

    // 生产者协程
    launch {
        for (i in 1..5) {
            channel.send(i) // 发送数据到Channel
            println("Sent: $i")
        }
        channel.close() // 生产结束，关闭Channel
    }

    // 消费者协程
    launch {
        for (item in channel) { // 遍历Channel中的数据
            println("Received: $item")
        }
    }
}

在上述代码中：

1. 首先创建了一个 Channel<Int>，用于传递 Int 类型的数据。
2. 生产者协程通过 channel.send() 方法向 Channel 发送数据，并在发送后打印已发送的信息。
3. 发送完毕后，通过 channel.close() 关闭 Channel，表示生产结束。
4. 消费者协程通过 for (item in channel) 这种方式遍历 Channel 中的数据，一旦有数据可用就接收并打印。当 Channel 关闭且所有数据被消费完，遍历结束。