Quarkus/Mutiny如何触发无需等待的后台异步任务？

你可以通过 Mutiny 提供的副作用操作符 + 异步订阅的方式实现主任务立即返回、后台任务异步执行的需求，完全贴合响应式编程模型，比手动使用ManagedExecutor更自然：

修改后的代码示例 #

import io.smallrye.mutiny.Uni;
import io.smallrye.mutiny.infrastructure.Infrastructure;
import org.jboss.logging.Logger;

import jakarta.ws.rs.GET;
import jakarta.ws.rs.Path;

Uni<Integer> mainJob() {
    // 主任务逻辑
    return Uni.createFrom().item(1);
}

Uni<Void> sideJob(int n) {
    // 后台任务逻辑，这里模拟耗时操作
    logger.log("sideJob 启动，处理参数: " + n);
    // 注意：必须返回 Uni<Void> 类型，否则编译报错
    return Uni.createFrom().voidItem();
}

private static final Logger logger = Logger.getLogger(YourClassName.class);

@Path("test")
@GET
Uni<Integer> testExample() {
    return mainJob()
            // 使用 invoke 执行副作用，不会阻塞主任务流程
            .invoke(n -> {
                // 异步订阅后台任务，不等待其完成
                sideJob(n)
                        // 指定后台任务在 worker 线程池执行（可选，适合耗时操作）
                        .runSubscriptionOn(Infrastructure.getDefaultWorkerPool())
                        // 订阅任务，处理成功/失败日志
                        .subscribe().with(
                                () -> logger.debug("sideJob 执行完成"),
                                error -> logger.error("sideJob 执行失败", error)
                        );
            });
}

关键说明 #

1. invoke操作符：替代原代码的onItem().call()，invoke仅执行副作用逻辑，不会等待后续Uni完成，主任务会立即返回结果。
2. 异步订阅后台任务：后台任务的Uni必须手动调用subscribe()才会执行（Mutiny的Uni是冷订阅模型），通过这种方式触发后台执行，不阻塞主流程。
3. 线程池控制：如果后台任务是CPU密集型或耗时操作，使用runSubscriptionOn(Infrastructure.getDefaultWorkerPool())将任务切换到Quarkus的默认worker线程池，避免占用IO线程。
4. 错误处理：在subscribe().with()中添加错误日志，确保后台任务的异常能被捕获记录，避免静默失败。

内容的提问来源于stack exchange，提问作者Jie Huang