SpringBoot普通消息隊列線程池配置

package com.liuhuan.study.config;

import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.*;

/**
 * @author LiuHuan
 * @date 2019-10-08 15:42
 * @desc 線程池
 */
@Configuration
public class ThreadPoolConfig {

    /**
     * 線程池維護線程的最少數量
     */
    private static final int CORE_POOL_SIZE = Runtime.getRuntime().availableProcessors();

    /**
     * 線程池維護線程的最大數量
     */
    private static final int MAX_POOL_SIZE = 20;

    /**
     * 空閑線程等待工作的超時時間
     */
    private static final long KEEP_ALIVE_TIME = 1000L;

    /**
     * 線程池所使用的緩沖隊列大小
     */
    private final static int WORK_QUEUE_SIZE = 10;



    /**
     * 消息隊列線程池
     */
    @Bean(value = "processThreadPool")
    public ExecutorService processThreadPool(){
        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
            .setNameFormat("process-thread-%d").build();

        ExecutorService pool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue<Runnable>(WORK_QUEUE_SIZE), namedThreadFactory, new ThreadPoolExecutor.DiscardOldestPolicy());
        return pool ;
    }

}