如何用Parcel或Channel解决工作池进程间耗材请求的数据交互问题

1. 基于Channel构建适配工作池的耗材通信机制 #

既然Parcel无法序列化传递，直接用Channel搭建一套贴合你场景的请求-分发逻辑：

• 创建池级请求Channel：工作池启动时初始化一个Channel<耗材请求>，所有Worker共享这个Channel用来发请求；同时启动一个独立的耗材管理协程，专门监听这个Channel处理请求。
• Worker侧请求逻辑：每个Worker需要耗材时，向共享Channel发送包含自身标识、耗材类型/数量、以及自己专属的返回Channel的请求结构体。
• 耗材协程处理逻辑：维护耗材库存，收到请求后若有货，直接通过Worker的返回Channel发耗材；库存不足就把请求加入等待队列，等补货后再处理。

示例伪代码：

// 定义请求结构体
data class SupplyRequest(
    val workerId: String,
    val supplyType: SupplyType,
    val needCount: Int,
    val replyChannel: Channel<Supply>
)

// 工作池初始化
val supplyRequestChannel = Channel<SupplyRequest>(Channel.UNLIMITED)
CoroutineScope(Dispatchers.IO).launch {
    val inventory = mutableMapOf<SupplyType, Int>().withDefault { 0 }
    val pendingRequests = mutableListOf<SupplyRequest>()

    for (req in supplyRequestChannel) {
        val available = inventory.getValue(req.supplyType)
        if (available >= req.needCount) {
            inventory[req.supplyType] = available - req.needCount
            req.replyChannel.send(Supply(req.supplyType, req.needCount))
        } else {
            pendingRequests.add(req)
        }
    }
}

// Worker实现
class Worker(val id: String) {
    private val replyChannel = Channel<Supply>(Channel.CONFLATED)

    suspend fun executeTask() {
        // 发送耗材请求
        supplyRequestChannel.send(SupplyRequest(id, SupplyType.INK, 3, replyChannel))
        // 等待接收耗材
        val supply = replyChannel.receive()
        // 用耗材执行任务
    }
}

2. 绕开Parcel序列化问题的思路 #

如果想保留Parcel的便捷性，可以换个方式用：

• Worker内部初始化Parcel：不要跨任务传递Parcel对象，让每个Worker自己负责初始化、管理所需的Parcel实例，直接在Worker内部使用，完全避开序列化问题。
• 封装Parcel逻辑为可序列化服务：把Parcel的读写操作封装成实现Serializable或Parcelable的工具类，传递这个工具类给任务，Worker内部调用工具类方法处理数据，而非传递Parcel本身。

3. Channel复杂场景进阶用法 #

• 多路事件监听：用select让耗材管理协程同时监听请求Channel、库存补货通知、Worker退出信号等多个Channel，处理多类型事件。
• 请求超时控制：Worker发送请求后，用withTimeout包裹receive，避免因库存不足导致Worker无限阻塞。
• 按耗材类型拆分Channel：给不同类型的耗材创建单独的请求Channel，让耗材协程并行处理不同类型的请求，提升分发效率。

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