Android Logger基于Kotlin Channel的线程安全、背压与内存优化方案

问题背景 #

我在Android中实现了一个日志打印用的Logger类，初始代码如下：

class Logger {
    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Default)
    private val channel = Channel<String>(50)
    private val messages = mutableListOf<String>()

    init {
        // 消费日志消息
        scope.launch {
            channel.consumeEach { message -> messages.add(message) }
        }
    }

    fun log(message: String) {
        // 生产日志消息
        scope.launch { channel.send(message) }
    }
}

日志来自多线程场景，引入Channel是为了保证线程安全，同时利用它的特性实现背压策略——暂停过快的生产者，避免未处理日志持续累积。但发现一个问题：当Channel缓冲区存满50条日志后，若仍有新日志产生，每次调用log()都会创建新协程并挂起，这些协程对象的内存占用远大于String，反而导致内存开销增长。

我产生了两个疑问：

• 若移除Channel直接让messages列表自由增长，是否能更节省内存？
• 针对需要同时保证线程安全和背压策略的场景，有没有更优的实现方案？

优化后的解决方案 #

最终我找到了符合需求的实现方式：

class Logger {
    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Default)
    private val channel = Channel<String>(50)
    private val messages = mutableListOf<String>()
    private val logDb by lazy { Room.databaseBuilder(context, LogDatabase::class.java, "log_db").build() }

    init {
        scope.launch {
            channel.consumeEach { message -> messages.add(message) }
        }
    }

    fun log(message: String) {
        // 以非挂起方式发送日志到Channel，缓冲区满时将日志插入数据库
        channel.trySend(message).onFailure {
           val logEntity = LogEntity(UUID.randomUUID().toString(), message.toString())
           scope.launch { logDb.logDao().insert(logEntity) } 
        }
    }
}

方案解析 #

• 避免协程堆积：改用trySend替代原有的launch + send，trySend是非挂起函数，Channel缓冲区满时不会创建并挂起新协程，彻底消除了协程对象带来的额外内存开销。
• 降级存储保障日志不丢失：当trySend失败（缓冲区已满），将日志持久化到Room数据库，既避免了内存溢出风险，又保证了日志不会丢失。
• 保留原有消费逻辑：继续通过consumeEach处理缓冲区中的日志到内存列表，兼顾了内存中日志的快速访问需求。
• 直接移除Channel的弊端：如果直接使用线程安全的列表（比如ConcurrentLinkedQueue），虽然内存开销可能更低，但无法实现背压策略——当生产者速度远快于消费者时，内存中的日志会无限制增长，最终可能引发OOM，因此这种方案不符合需求。

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