如何在Vertx(v3.5)事件循环线程上执行CompletableFuture.handleAsync？

嘿，我来帮你解决这个困扰！你想要用handleAsync把回调逻辑放到Vertx的事件循环线程上执行，核心就是要拿到Vertx事件循环对应的Executor，然后把它作为第二个参数传给handleAsync就行——之前的问题就是没传对Executor，导致回调跑到ForkJoin池里了。

具体操作步骤和代码示例 #

1. 先拿到Vertx事件循环的Executor #

在Vertx里，每个Context都自带了对应的Executor，你可以直接这么获取：

Executor vertxEventLoopExecutor = vertx.getOrCreateContext().executor();

这个Executor会把你提交的任务精准调度到当前的Vertx事件循环线程上，完全符合你的需求。

2. 改造你的handleAsync调用 #

把上面拿到的Executor传进去，替换掉默认的线程池。给你对比下前后的代码：

原来的handle写法（或你之前尝试的无效写法）

CompletableFuture<Object> future = xyz.someMethod();

// 原来用handle的方式，回调不在事件循环上，只能套runOnContext转线程
future.handle((result, throwable) -> {
    if (throwable != null) {
        vertx.runOnContext(v -> handleError(throwable));
    } else {
        vertx.runOnContext(v -> handleResult(result));
    }
    return null;
});

正确的handleAsync写法

// 先拿到事件循环的Executor
Executor vertxEventLoopExecutor = vertx.getOrCreateContext().executor();

CompletableFuture<Object> future = xyz.someMethod();

// 把Executor传给handleAsync，回调直接跑在事件循环上
future.handleAsync((result, throwable) -> {
    // 现在这段代码妥妥在Vertx事件循环线程里执行，不用再套runOnContext啦！
    if (throwable != null) {
        handleError(throwable);
    } else {
        handleResult(result);
    }
    return null;
}, vertxEventLoopExecutor);

为啥之前用runOnContext不管用？ #

你之前试着把整个代码块放到vertx.runOnContext()里，但handleAsync如果不指定Executor，默认会用Java的ForkJoinPool.commonPool()，所以回调逻辑还是会跑到那个通用线程池里，和你外层的runOnContext没关系。只有显式传入Vertx的Executor，才能强制让回调跑在事件循环上。

几个要注意的小细节 #

• 一定要确保你在调用vertx.getOrCreateContext()的时候，当前线程已经是Vertx的事件循环线程（比如在Verticle的start方法里，或者已经在某个Vertx的回调逻辑中），这样拿到的Context才是正确的事件循环Context，对应的Executor才会把任务放到正确的线程上。
• 如果你的回调逻辑里有阻塞操作（比如数据库同步查询、文件IO），那可别用事件循环线程！这种情况应该用Vertx的Worker线程池（比如vertx.createSharedWorkerExecutor("my-worker-pool")），不然会阻塞事件循环，拖垮整个Vertx应用的性能。

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