worker - Vert.x 工作线程阻塞

Question

我有一个 vert.x Standard Verticle 基本上，它解析 HttpRequest 并准备 JsonObject，然后我通过事件总线发送 JSONObject。在另一个 Worker Verticle 中，该事件被消耗并开始执行(包括对 Penthao 数据集成 Java API 的调用)它正在阻塞 API。完成“.kjb”文件的执行大约需要 30 分钟。但是 vert.x 不断警告 Worker Thread Block，所以我的问题是 vert.x 中解决这种情况的最佳实践是什么。 任何帮助将不胜感激。

Answer 1

根据 vertx doc所有阻塞操作都需要在代码中执行

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

所以这是所有阻塞任务的最佳实践。