项目中创建多线程时，使用常见的三种线程池创建方式，单一、可变、定长都有一定问题，原因是FixedThreadPool和SingleThreadExecutor底层都是用LinkedBlockingQueue实现的，这个队列最大长度为Integer.MAX_VALUE，容易导致OOM。所以实际生产一般自己通过ThreadPoolExecutor的7个参数，自定义线程池：

ExecutorService threadPool=new ThreadPoolExecutor(2,5,
             1L,TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(3),
             Executors.defaultThreadFactory(),
             new ThreadPoolExecutor.AbortPolicy());

一、创建线程池的7个参数

• corePoolSize线程池的核心线程数
• maximumPoolSize能容纳的最大线程数
• keepAliveTime空闲线程存活时间
• unit 存活的时间单位
• workQueue 存放提交但未执行任务的队列
• threadFactory 创建线程的工厂类
• handler 等待队列满后的拒绝策略

使用线程池时，阿里巴巴P3C代码规约插件将提示：

手动创建线程池--不允许Executors.newFixedThreadPool创建线程池

线程池

static ExecutorService taskExe = Executors.newFixedThreadPool(10);

二、规避资源耗尽的风险，生产上的推荐解法：

import com.google.common.util.concurrent.ThreadFactoryBuilder;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
//引入依赖包，创建线程池
private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("thread-call-runner-%d").build();
private ExecutorService taskExe = new ThreadPoolExecutor(10,20,200L,TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(),namedThreadFactory);

推荐：

主流Java进阶技术（学习资料分享）