Quarkus：如何设置全局自定义ThreadPoolExecutor

Question

我正在研究一个项目，其中上下文和会话由ThreadLocal使用ThreadPoolExecutor安全地管理（信息从线程传递到ThreadPoolExecutor内部的另一个线程）。

我们有：

1. ThreadPoolExecutor:它实现beforeExecute和afterExecute方法行为，以确保信息从线程传递到另一个线程，并在afterExecutre方法中清除线程上下文。
2. ThreadFactory:负责创建保存ThreadLocal会话信息的自定义命名线程。
3. 在BeforeExecute中使用的自定义可运行程序。此运行可使用原始的一个+其他所需的信息（例如会话）

Answer 1

Quarkus版本:1.9.1.最终版

爪哇：11

您可以通过配置属性来优化Quarkus主服务执行器。查看所有quarkus.thread-pool.*属性，然后将其用作常规服务执行器。

为了将这个线程池注入到您的服务中，请确保通过添加以下扩展来支持上下文传播。/MVNW quarkus：add-extensions=“quarkus-smallrye-context-propagation”，您可以在此链接中看到

将主服务执行器注入您的服务非常简单：

@Inject ManagedExecutor Exec；

创建一个单独的服务执行器这是另一种方法（然而，您应该问自己，使用一个单独的执行器我得到了什么？，我在寻找什么？），也许有意义，我想这取决于具体情况。在“本例”中，您可以创建自己的ManagedExcutor并使用它，例如：

import io.quarkus.runtime.Startup;
import org.eclipse.microprofile.context.ManagedExecutor;

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Named;
import javax.ws.rs.Produces;

public class Producers {

    private final static int POOL_SIZE = 4; // TODO move on this hardcode properties to a config file
    private final static int POOL_QUEUE_SIZE = 10;

    @Startup // Instanciated at start-time
    @ApplicationScoped // Only one instance for all your app (Singleton)
    @Produces 
    @Named("customServiceExecutor") // tag your instance, because remember that you will have also another ServiceExecutor (the default one)
    ManagedExecutor managedCustomExecutor() {

        System.out.println("customServiceExecutor created (once)!.");

        return ManagedExecutor.builder()
                .maxAsync(POOL_SIZE)
                .maxQueued(POOL_QUEUE_SIZE)
                .build();
    }

}

import io.smallrye.context.api.NamedInstance;
import org.eclipse.microprofile.config.inject.ConfigProperty;
import org.eclipse.microprofile.context.ManagedExecutor;


import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

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

    @ConfigProperty(name = "org.pjgg.greeting")
    private String greeting;

    @Inject
    @NamedInstance("customServiceExecutor")
    ManagedExecutor delorean;

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    public String hello() {
        System.out.println(java.lang.Thread.activeCount());

        var promise = delorean.supplyAsync(()-> "You will see this in the future !!!");
        promise.thenAccept(System.out::println);
        System.out.println(java.lang.Thread.activeCount());

        return greeting;
    }
}