在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);
    }
}

通過以上步驟，我們就成功配置和使用了自定義線程池來處理異步任務。