SpringBoot实现全局线程池管理、动态线程池、线程池监控和线程池编排详解

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

@Configuration
public class ThreadPoolConfig {

    @Bean
    public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心线程数
        executor.setCorePoolSize(5);
        // 最大线程数
        executor.setMaxPoolSize(10);
        // 队列容量
        executor.setQueueCapacity(25);
        // 线程池中的线程名称前缀
        executor.setThreadNamePrefix("taskExecutor-");
        // 初始化线程池
        executor.initialize();
        return executor;
    }
}

# application.properties
threadpool
	core-size=5
	max-size=10
	queue-capacity=25

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@Configuration
public class DynamicThreadPoolConfig {

    @Value("${threadpool.core-size}")
    private int coreSize;

    @Value("${threadpool.max-size}")
    private int maxSize;

    @Value("${threadpool.queue-capacity}")
    private int queueCapacity;

    @Bean
    public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(coreSize);
        executor.setMaxPoolSize(maxSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setThreadNamePrefix("dynamicTaskExecutor-");
        executor.initialize();
        return executor;
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

@Component
@EnableScheduling
public class ThreadPoolMonitor {

    @Autowired
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;

    @Scheduled(fixedRate = 5000)
    public void monitorThreadPool() {
        System.out.println("Current Active Threads: " + threadPoolTaskExecutor.getActiveCount());
        System.out.println("Core Pool Size: " + threadPoolTaskExecutor.getCorePoolSize());
        System.out.println("Max Pool Size: " + threadPoolTaskExecutor.getMaxPoolSize());
        System.out.println("Queue Capacity: " + threadPoolTaskExecutor.getQueueCapacity());
        System.out.println("Task Count: " + threadPoolTaskExecutor.getThreadPoolExecutor().getTaskCount());
        System.out.println("Completed Task Count: " + threadPoolTaskExecutor.getThreadPoolExecutor().getCompletedTaskCount());
    }
}

@Configuration
public class ThreadPoolOrchestrationConfig {

    @Bean
    public ThreadPoolTaskExecutor taskExecutor1() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(50);
        executor.setThreadNamePrefix("taskExecutor1-");
        executor.initialize();
        return executor;
    }

    @Bean
    public ThreadPoolTaskExecutor taskExecutor2() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(15);
        executor.setMaxPoolSize(30);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("taskExecutor2-");
        executor.initialize();
        return executor;
    }

    @Bean
    public ThreadPoolTaskExecutor taskExecutor3() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(20);
        executor.setThreadNamePrefix("taskExecutor3-");
        executor.initialize();
        return executor;
    }
}

@Autowired
private ThreadPoolTaskExecutor taskExecutor1;

@Autowired
private ThreadPoolTaskExecutor taskExecutor2;

public void executeTask(String taskType) {
    if ("type1".equals(taskType)) {
        taskExecutor1.execute(() -> {
            // 执行任务1
        });
    } else if ("type2".equals(taskType)) {
        taskExecutor2.execute(() -> {
            // 执行任务2
        });
    }
}