首页 > 解决方案 > 我怎么知道有多少消息在等待 Actor 处理

问题描述

我正在使用来自 Kotlin 协程的演员,如下所示:

actor<Action>(CommonPool, 0, parent = job) {
        consumeEach { action ->
            when (action) {
                is Spin -> spin(action.id)
                is Done -> action.ack.complete(true)
            }
        }
    }

出于调试目的,我想知道有多少消息在通道上等待处理。这怎么可能?

标签: kotlinactorkotlinx.coroutines

解决方案


推荐阅读