如何将 CompletableFuture 转换为 Vert.X Future

Question

我正在尝试在协程中使用 vertx 反应式 sql 客户端执行数据库事务。 不知何故，我无法弄清楚如何将 CompletableFuture 转换为所需的 io.vertx.core.Future 类型。是否有任何辅助方法或扩展可以轻松做到这一点？

val client : PgPool
... 

suspend fun someServiceFunction () {
    coroutineScope {
        client.withTransaction { connection ->
            val completableFuture = async {
                repository.save(connection, requestDTO)  //This is a suspend function
            }.asCompletableFuture()

            //Return type has to be a io.vertx.core.Future
            //How can I transform the completableFuture to it ?
        }
    }
}

感谢您的帮助！

Answer 1

Vert.x Future 有转换方法：

future = Future.fromCompletionStage(completionStage, vertxContext)

Answer 2

我从asCompletableFuture() 的代码中对此进行了改编，以用作替代方案。免责声明：我没有使用 Vert.x，也没有对此进行测试。

fun <T> Deferred<T>.asVertxFuture(): Future<T> {
    val promise = Promise.promise<T>()
    invokeOnCompletion {
        try {
            promise.complete(getCompleted())
        }  catch (t: Throwable) {
            promise.fail(t)
        }
    }
    return promise.future()
        .onComplete { result ->
            cancel(result.cause()?.let {
                it as? CancellationException ?: CancellationException("Future was completed exceptionally", it)
            })
        }
}

我想知道在 Vert.x 中混合协程是否会损害性能，因为您没有使用 Vert.x 线程池。也许你可以创建一个Dispatchers.Vertx 借用它的线程池。