java - *垂直x* : How to handle in synchronous code

Question

我有一个方法可以有条件地进行异步调用。下面是它的简化版本。如果满足“条件”，我希望它返回。

private void myMethod(RoutingContext routingContext, Handler<AsyncResult<AsyncReply>> handler) {
    //...
    if (condition) {
        // this does not work
        handler.handle(Future.succeededFuture(new AsyncReply(200, "")));
    }

    // here I do an async call and use the handler appropriately
    HttpClientRequest productRequest = client.getAbs(url, h -> h.bodyHandler(bh -> {
           // works  
           handler.handle(Future.succeededFuture(new AsyncReply(200, "")));
    }

}

我怎样才能做到这一点？

Answer 1

根据文档，您不能直接从事件循环调用阻塞操作，因为这会阻止它执行任何其他有用的工作。那么如何才能做到这一点呢？

这是通过调用executeBlocking来指定要执行的阻塞代码以及在执行阻塞代码时异步回调的结果处理程序来完成的。

            vertx.executeBlocking(future -> {
              // Call some blocking API that takes a significant amount of time to return
              String result = someAPI.blockingMethod("hello");
              future.complete(result);
            }, res -> {
              System.out.println("The result is: " + res.result());
            });