维特。编写协同程序阻塞代码的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中提取线程池的方法。十、

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) }
        )
    }
}