spring多线程实现+合理设置最大线程数和核心线程数

在Spring中，你可以使用ThreadPoolTaskExecutor来配置线程池，并通过@Configuration类来定义线程池的Bean。以下是一个配置线程池的例子，其中设置了最大线程数和核心线程数：

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;
import java.util.concurrent.ThreadPoolExecutor;
 
@Configuration
@EnableAsync
public class AsyncConfig {
 
    // 配置核心线程数
    private int corePoolSize = 5;
 
    // 配置最大线程数
    private int maxPoolSize = 10;
 
    // 配置队列大小
    private int queueCapacity = 100;
 
    @Bean(name = "threadPoolTaskExecutor")
    public Executor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("MyThreadPoolTaskExecutor-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

在这个配置中，corePoolSize是线程池中常驻的线程数，即使线程处于空闲状态也不会被回收。maxPoolSize是线程池中最大线程数，当任务过多导致队列也满时，线程池会创建最大线程数以处理任务。queueCapacity是任务队列的容量。

你可以根据实际需求调整corePoolSize、maxPoolSize和queueCapacity的值。keepAliveSeconds是线程空闲后的存活时间，threadNamePrefix是线程名的前缀，RejectedExecutionHandler是拒绝策略，当线程池无法处理更多任务时的策略，这里使用的是CallerRunsPolicy，意味着提交任务的线程自己会去执行这个任务。

在你的服务类中，使用@Async注解来指定使用这个线程池来执行方法：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
 
@Service
public class AsyncService {
 
    @Async("threadPoolTaskExecutor")
    public void executeAsyncTask() {
        // 异步任务的逻辑
    }
}

这样配置后，你就可以在Spring应用中使用线程池来执行异步任务了。