Spring boot 生成线程池

@Configuration
public class ConvertThreadPoolConfig {
    private static final AtomicInteger threadIndex = new AtomicInteger(0);
    
    @Bean(value = "convertThreadPool")
    public ExecutorService convertThreadPool() {
        ThreadFactory threadFactory = new ThreadFactory() {
            
            @Override
            public Thread newThread(Runnable r) {
                Thread thread = new Thread(r, "convert-thread-" + threadIndex.incrementAndGet());
                thread.setDaemon(true);
                return thread;
            }
        };
        
        ExecutorService pool = new ThreadPoolExecutor(2, 4, 0L, TimeUnit.MILLISECONDS, 
                new ArrayBlockingQueue<Runnable>(10), threadFactory, new ThreadPoolExecutor.CallerRunsPolicy());
        return pool;
    }
}
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容