我可以配置特定Quarkus Vertx ConsumeEvent的池大小吗？

Question

根据quarkus指南-所有配置选项，参数< code > quar kus . vertx . worker-pool-size 允许我配置“工作线程池的线程大小”。

是否可以像这样配置特定QUKUS Consume事件的池大小：

    @io.quarkus.vertx.ConsumeEvent(value = "my-consume-event", blocking = true)
    public void start(String value) {
      // do the work
    }

我想设置线程的数量，可以处理这个my-usene-事件而不改变全局quarkus.vertx.worker-pool-size。

在SmallRye Reactive Messaging指南中，有一个我想做的例子。

在这里，我可以使用一个Blocking注释，为其定义一个名称并配置线程池：

@Outgoing("Y")
@Incoming("X")
@Blocking("my-custom-pool")
public String process(String s) {
  return s.toUpperCase();
}

为上述工作池指定并发性需要定义以下配置属性:

smallrye.messaging.worker.my-custom-pool.max-concurrency=3

在本例中，我可以配置线程池的大小，该线程池将处理来自＜code＞我的自定义池＜/code＞的消息。

谢谢

我尝试为< code > @ io . small rye . common . annotation . blocking(" my-custom-pool ")批注设置一个值，但收到以下错误:

The attribute value is undefined for the annotation type Blocking

我正在使用此依赖项：

    <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-vertx</artifactId>
    </dependency>

我还在我的 GitHub 帐户上创建了这个项目来做这个测试。

package org.acme;

import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.core.Response;

import org.jboss.logging.Logger;

import io.vertx.core.eventbus.EventBus;

@Path("/hello")
public class GreetingResource {
    private static final Logger LOG = Logger.getLogger(GreetingResource.class);

    @Inject
    EventBus eventBus;

    @GET
    public Response hello() {
        LOG.info("hello()");
        eventBus.send("my-consume-event", null);
        return Response
                .status(Response.Status.ACCEPTED)
                .build();
    }

    @io.quarkus.vertx.ConsumeEvent("my-consume-event")
    // @io.smallrye.common.annotation.Blocking("my-custom-pool")
    @io.smallrye.common.annotation.Blocking
    public void start(String value) {
        try {
            LOG.info("before the sleep");
            Thread.sleep(5000);
            LOG.info("after the sleep");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Answer 1

您应该能够使用< code > @ io . small rye . common . annotation . blocking 批注:

@ConsumeEvent("my-consume-event")
@Blocking("my-custom-pool")
public void start(String value) {
  // do the work
}

并在application.properties中配置您的池大小：

smallrye.messaging.worker.my-custom-pool.max-concurrency=3

编辑

实际上，@io.smallrye.reactive.messaging.annotations.Block在用@ConsumeEvent注释的方法上不受支持。

此外，根据ConsumeEvent在错误的执行器上阻塞线程服务#19911，事件似乎是在默认的Quarkus执行器上执行的。