src/main/java/com/yj/oa/common/conf/ThreaPoolConf.java

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.yj.oa.common.conf;

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @author 永健
 * 线程池
 */
@Configuration
public class ThreaPoolConf{
    /** 核心线程数*/
    private static final int  CORE_POOL_SIZE= 2;
    /** 最大线程数*/
    private static final int  MAX_NUM_POOL_SIZE= 10;
    /** 空闲时间*/
    private static final long  KEEPALL_LIVETIME= 60;


    @Bean
    public ThreadPoolExecutor threadPoolExecutor(
            @Qualifier("Handler") RejectedExecutionHandler rejectedExecutionHandler)
    {
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                CORE_POOL_SIZE,
                MAX_NUM_POOL_SIZE,
                KEEPALL_LIVETIME,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(50),
                rejectedExecutionHandler
        );

        return threadPoolExecutor;
    }

    @Bean("Handler")
    public RejectedExecutionHandler rejectedExecutionHandler()
    {
        return new ThreadPoolExecutor.AbortPolicy();
    }
}