springboot配置自定义线程池

在Spring Boot中配置自定义线程池，可以通过实现`TaskExecutor`接口，然后在`@Configuration`类中创建`ThreadPoolTaskExecutor`实例。下面是一个示例：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
@EnableAsync
public class AppConfig {

    @Bean(name = "myThreadPool")
    public Executor myThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("MyThreadPool-");
        executor.initialize();
        return executor;
    }
}

在上面的示例中，我们通过`ThreadPoolTaskExecutor`类创建了一个名为`myThreadPool`的自定义线程池。该线程池的核心线程池大小为10，最大线程池大小为20，队列容量为100。线程名前缀为"MyThreadPool-"，在这个线程池中每个线程的名字都会以"MyThreadPool-"开头。

接下来，在需要异步执行的方法上使用`@Async`注解，并指定线程池名称，如下所示：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.concurrent.Executor;

@Service
public class MyService {

    @Autowired
    @Qualifier("myThreadPool")
    private Executor executor;

    @Async("myThreadPool")
    public void doSomething() {
        // 异步执行的代码
    }
}

在上面的示例中，我们将`Executor`注入到`MyService`中，并在`doSomething()`方法上使用`@Async("myThreadPool")`注解指定线程池名称为"myThreadPool"。这样，`doSomething()`方法就会以异步的方式执行，并且使用我们自定义的线程池。