13518219792
如何通过ThreadPoolExecutor的方式创建线程池，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
创新互联长期为近千家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为西藏企业提供专业的成都网站制作、成都网站设计，西藏网站改版等技术服务。拥有10年丰富建站经验和众多成功案例,为您定制开发。
线程池不建议使用Executors去创建，而是通过ThreadPoolExecutor的方式，这样的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。
Executors各个方法的弊端：
newFixedThreadPool 和 newSingleThreadExecutor:
主要问题是堆积的请求处理队列可能会耗费非常大的内存，甚至OOM。(笔者注：阻塞队列均采用LinkedBlockingQueue)
newCachedThreadPool 和 newScheduledThreadPool:
主要问题是线程数最大数是Integer.MAX_VALUE，可能会创建数量非常多的线程，甚至OOM。
Executors提供了四种创建线程池的方法，实际上Executors的底层也是调用了ThreadPoolExecutor。函数定义如下:
public ThreadPoolExecutor(int corePoolSize, // 线程池的核心线程数 int maximumPoolSize, // 线程池的最大线程数 long keepAliveTime, // 当线程数大于核心时，多余的空闲线程等待新任务的存活时间。 TimeUnit unit, // keepAliveTime的时间单位 ThreadFactory threadFactory, // 线程工厂 BlockingQueueworkQueue,// 用来储存等待执行任务的队列 RejectedExecutionHandler handler // 拒绝策略 )
线程池运行原理:
workQueue有以下七种选择：
ArrayBlockingQueue： 一个由数组结构组成的有界阻塞队列(数组结构可配合指针实现一个环形队列)。
LinkedBlockingQueue： 一个由链表结构组成的有界阻塞队列，而在未指明容量时，容量默认为Integer.MAX_VALUE。
PriorityBlockingQueue： 一个支持优先级排序的无界阻塞队列，对元素没有要求，可以实现Comparable接口也可以提供Comparator来对队列中的元素进行比较，跟时间没有任何关系，仅仅是按照优先级取任务。
DelayQueue： 同PriorityBlockingQueue，也是二叉堆实现的优先级主阻塞队列。要求元素都实现Delayed接口，通过执行时延从队列中提取任务，时间没到任务取不出来。
SynchronousQueue： 一个不存储元素的阻塞队列，消费者线程调用take()方法的时候就会发生阻塞，直到有一个生产者线程生产了一个元素，消费者线程就可以拿到这个元素并返回；生产者线程调用put()方法的时候就会发生阻塞，直到有一个消费者线程消费了一个元素，生产者才会返回。
LinkedTransferQueue： 它是ConcurrentLinkedQueue、LinkedBlockingQueue和SynchronousQueue的结合体，但是把它用在ThreadPoolExecutor中，和LinkedBlockingQueue行为一致。
LinkedBlockingDeque： 使用双向队列实现的双端阻塞队列，双端意味着可以像普通队列一样FIFO(先进先出)，可以以像栈一样FILO(先进后出)
handler有以下四种取值：
AbortPolicy（默认）：丢弃任务并抛出RejectedExecutionException异常。
CallerRunsPolicy：由调用线程处理该任务。(例如io操作，线程消费速度没有NIO读取快，可能导致阻塞队列一直增加，此时可以使用这个模式)
DiscardPolicy：丢弃任务，但是不抛出异常。 （可以配合这种模式进行自定义的处理方式）
DiscardOldestPolicy：丢弃队列最早的未处理任务，然后重新尝试执行任务（重复执行）
关于如何通过ThreadPoolExecutor的方式创建线程池问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联行业资讯频道了解更多相关知识。
