kotlin - Vert.x编写协程阻止代码的方法

Question

我确实有同时使用协程和Vert.x的项目。

我正在尝试编写包装器函数以在vertx工作线程池上运行阻塞代码

就像是:

suspend inline fun <T> executeOnWorkerThread(crossinline block: () -> T) =
    withContext(**Vertx-Worker-ThreadPool**) {
        block()
    }

所以它可以像

 suspend fun usage(obj: Any): String = executeOnWorkerThread {
            try {
                // blocking code
            } catch (e: Exception) {
                // Exception handling
            }
        }

但这不是vert.x方式。而且我找不到从vert.x中提取线程池的方法

Answer 1

suspend fun <T> awaitBlockingUnordered(block: () -> T): T {
    return awaitResult { handler ->
        val ctx = Vertx.currentContext()
        ctx.executeBlocking<T>(
            { fut -> fut.complete(block()) },
            false,
            { ar -> handler.handle(ar) }
        )
    }
}