如何使用I/O线程？

Question

根据该条：https://quarkus.io/blog/resteasy-reactive-smart-dispatch/我应该能够通过使用@NonBlocking“just”注释方法来使用I/O线程。

当使用最新的夸克快速入门并修改入门示例时：

@Path("/hello")
public class GreetingResource {

    @Inject
    GreetingService service;

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    @Path("/greeting/{name}")
    @Blocking
    public String greeting(@PathParam String name) {
        System.out.println( "greeting, isWorker: " + ( (io.vertx.core.impl.VertxThread)Thread.currentThread() ).isWorker() );
        return service.greeting(name);
    }

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    @NonBlocking
    public String hello() {
        System.out.println( "hello, isWorker: " + ( (io.vertx.core.impl.VertxThread)Thread.currentThread() ).isWorker() );
        return "hello";
    }
}

我希望为hello方法获得一个I/O线程。然而，结果是：

2021-12-28 14:07:17,990 INFO  [io.quarkus] (Quarkus Main Thread) getting-started 1.0.0-SNAPSHOT on JVM (powered by Quarkus 2.6.1.Final) started in 0.543s. Listening on: http://localhost:8080
2021-12-28 14:07:17,990 INFO  [io.quarkus] (Quarkus Main Thread) Profile dev activated. Live Coding activated.
2021-12-28 14:07:17,991 INFO  [io.quarkus] (Quarkus Main Thread) Installed features: [cdi, resteasy, smallrye-context-propagation, vertx]
2021-12-28 14:07:17,991 INFO  [io.qua.dep.dev.RuntimeUpdatesProcessor] (vert.x-worker-thread-0) Live reload total time: 0.676s 
hello, isWorker: true
greeting, isWorker: true

因此，在这两种情况下（根据vert.x-worker-thread），都是一个工作线程，而不是I/O线程。

QUUKUS版本是2.6.1最终版

我错过了什么？

Answer 1

检查当前线程是否是类型io.vertx.core.impl.VertxThread不是检查您是否在事件循环上的方法，因为相同类型的线程也可以用于工作池。

正确的方法来做此检查在Quarkus是使用：

var onEventLoop = !io.quarkus.runtime.BlockingOperationControl.isBlockingAllowed()