Springboot中自定义线程池大小

作者：Odboy (opens new window)

本站地址：https://blog.odboy.cn (opens new window)

示例

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.*;

@Configuration
public class ThreadPoolConfig {

  @Bean
  public ExecutorService threadPool() {
    int corePoolSize = 5; // 核心线程数
    int maximumPoolSize = 10; // 最大线程数
    long keepAliveTime = 60L; // 空闲线程存活时间（秒）
    TimeUnit unit = TimeUnit.SECONDS; // 时间单位
    BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(100); // 工作队列大小

    ThreadFactory threadFactory = runnable -> {
      Thread thread = new Thread(runnable);
      thread.setName("my-thread-pool-" + thread.getId());
      return thread;
    };

    RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy(); // 拒绝策略

    return new ThreadPoolExecutor(
        corePoolSize,
        maximumPoolSize,
        keepAliveTime,
        unit,
        workQueue,
        threadFactory,
        handler
    );
  }
}