在Spring Boot中如何配置和使用自定义线程池

在Spring Boot中配置和使用自定义线程池可以通过使用@Configuration注解的类来实现。首先，创建一个继承自org.springframework.scheduling.annotation.AsyncConfigurerSupport的配置类，并重写getAsyncExecutor方法来配置自定义线程池，例如：

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
public class CustomAsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        executor.setThreadNamePrefix("CustomExecutor-");
        executor.initialize();
        return executor;
    }
}

在上面的配置中，我们创建了一个ThreadPoolTaskExecutor实例，并设置了核心线程数、最大线程数、队列容量和线程名称前缀等参数。然后通过调用initialize方法初始化线程池，并返回该线程池实例。

接着，在需要异步处理的方法上使用@Async注解来指定线程池，例如：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class MyService {

    @Async("getAsyncExecutor")
    public void asyncMethod() {
        // 异步处理的逻辑
    }
}

在上面的示例中，我们在asyncMethod方法上使用了@Async("getAsyncExecutor")注解，指定了使用名为getAsyncExecutor的线程池来执行这个异步方法。

最后，在Spring Boot应用的启动类上加上@EnableAsync注解来启用异步方法的支持，例如：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class MyApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

通过以上步骤，我们就成功配置和使用了自定义线程池来处理异步任务。