package cn.lili.common.thread;

import cn.lili.common.properties.ThreadProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**
 * 多线程配置
 *
 * @author Chopper
 * @version v1.0
 * @since
 * 2020-03-12 10:50 上午
 */
@Configuration
public class ThreadConfig implements AsyncConfigurer {


    @Autowired
    private ThreadProperties threadProperties;


    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//       核心线程数，默认为5
        executor.setCorePoolSize(threadProperties.getCorePoolSize());
//       最大线程数，默认为10
        executor.setMaxPoolSize(threadProperties.getMaxPoolSize());
//     队列最大长度，一般需要设置值为足够大
        executor.setQueueCapacity(threadProperties.getQueueCapacity());
//       线程池维护线程所允许的空闲时间，默认为60s
        executor.setKeepAliveSeconds(threadProperties.getKeepAliveSeconds());
//       允许超时关闭
        executor.setAllowCoreThreadTimeOut(threadProperties.getAllowCoreThreadTimeOut());
        executor.initialize();
        return executor;
    }
}