Quarkus中替换SmallRye Messaging的Vert.x工作线程池为无超时限制常规线程池的可行性及实现方法

没问题，完全可以替换掉Vert.x工作线程池，避开那烦人的60秒阻塞警告！Quarkus搭配SmallRye Messaging给了我们足够的灵活性，来定制适合长时间阻塞任务的线程池。下面一步步给你讲怎么实现：

一、可行性说明 #

Vert.x工作线程的60秒阻塞警告是它内置的线程健康检测机制，目的是提醒开发者避免长时间阻塞Vert.x线程（毕竟Vert.x主打非阻塞）。但你的场景就是需要处理长耗时任务，所以用**常规JDK线程池（比如Executors.newFixedThreadPool）**来替换是完全合理的，这类线程池没有内置的阻塞超时检测，正好匹配你的需求。

二、具体实现步骤 #

1. 创建自定义线程池的CDI Producer #

首先我们要在Quarkus里创建一个CDI Bean，生成我们需要的固定大小线程池，同时还要处理线程池的关闭，避免资源泄漏：

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.enterprise.inject.Produces;
import jakarta.inject.Named;
import jakarta.enterprise.inject.Disposes;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@ApplicationScoped
public class CustomThreadPoolProducer {

    // 生成自定义线程池，指定名称方便配置引用
    @Produces
    @Named("custom-long-task-executor")
    public ExecutorService customThreadPool() {
        // 这里创建固定大小为3的线程池，和你原来的max-concurrency保持一致
        return Executors.newFixedThreadPool(3);
    }

    // 应用关闭时自动关闭线程池，防止资源泄漏
    public void closeExecutor(@Disposes @Named("custom-long-task-executor") ExecutorService executor) {
        executor.shutdown();
    }
}

2. 修改SmallRye配置，绑定自定义线程池 #

打开你的application.properties，修改原来的worker池配置，指定使用我们刚刚创建的自定义Executor：

# 原来的max-concurrency可以保留，也可以去掉（因为线程池大小我们在代码里已经指定了）
smallrye.messaging.worker.custom-worker-pool.max-concurrency=3
# 关键配置：绑定到我们自定义的线程池Bean名称
smallrye.messaging.worker.custom-worker-pool.executor=custom-long-task-executor

3. 保持原有消费代码不变 #

你的消费方法不需要做任何改动，原来的@Blocking注解已经指定了使用custom-worker-pool，现在这个池会自动用我们的自定义线程池来处理任务：

@Incoming("incoming-messages")
@Blocking(ordered = false, value = "custom-worker-pool")
public Uni<Void> onExecutionReceive(final Message<JsonObject> message) {
    message.ack();
    // 放心执行你的长耗时阻塞任务吧，不会再触发超时警告了
    return Uni.createFrom().voidItem();
}

三、额外注意事项 #

• 线程池的大小要根据你的业务负载和服务器资源来调整，不要盲目设置过大，避免资源耗尽。
• 一定要实现@Disposes方法来关闭线程池，否则应用关闭后线程可能还在后台运行，导致内存泄漏。
• 如果你不需要严格的固定大小线程池，也可以用Executors.newCachedThreadPool或者自定义ThreadPoolExecutor来更精细地控制线程池参数（比如核心线程数、最大线程数、队列大小等）。

备注：内容来源于stack exchange，提问作者user1549094