认识ThreadPoolExecutor

线程池的创建

我们一般不会使用Executors创建线程池，因为会有规避资源耗尽的风险。举例说明：

• FixedThreadPool：允许的请求队列长度为 Integer.MAX_VALUE，可能会堆积大量的请求，从而导致 OOM。

• SingleThreadPool：和FixedThreadPool会面临同样的问题

• CachedThreadPool ：允许的创建线程数量为 Integer.MAX_VALUE，可能会创建大量的线程，从而导致 OOM。

• ScheduledThreadPool：和CachedThreadPool会面临同样的问题

而 Executors 中方法Executors.newFixedThreadPool()、Executors.newSingleThreadExecutor() 和 Executors.newCachedThreadPool()，底层都是通过 ThreadPoolExecutor 实现的。

ThreadPoolExecutor构造方法源码：

public ThreadPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory,
 RejectedExecutionHandler handler) {
 if (corePoolSize < 0 ||
 maximumPoolSize <= 0 ||
 maximumPoolSize < corePoolSize ||
 keepAliveTime < 0)
 throw new IllegalArgumentException();
 if (workQueue == null || threadFactory == null || handler == null)
 throw new NullPointerException();
 this.acc = System.getSecurityManager() == null ?
 null :
 AccessController.getContext();
 this.corePoolSize = corePoolSize;
 this.maximumPoolSize = maximumPoolSize;
 this.workQueue = workQueue;
 this.keepAliveTime = unit.toNanos(keepAliveTime);
 this.threadFactory = threadFactory;
 this.handler = handler;
}


• corePoolSize
   表示线程池的核心线程数。如果设置为0，则在没有任何任务时会销毁线程池；如果大于0，即使没有任务时也会保证线程池的线程数量等于此值。

• maximumPoolSize
   表示线程池在任务增多时，可以创建的最大线程数。

• keepAliveTime
   表示线程的存活时间，当线程池空闲时并且超过了此时间，多余的线程就会销毁，直到线程池中的线程数量销毁的等于 corePoolSize 为止，如果 maximumPoolSize 等于 corePoolSize，那么线程池在空闲的时候也不会销毁任何线程。

• unit
   表示存活时间的单位

• workQueue
   表示线程池执行的任务队列，当线程池的所有线程都在处理任务时，如果来了新任务就会缓存到此任务队列中排队等待执行。

• threadFactory
   表示线程的创建工厂

注意：如果corePoolSize设置的比较小，则会频繁的创建和销毁线程，如果设置的比较大，则会浪费系统资源，所以需要根据实际业务来调整此值。

提交线程任务

提交线程任务的两种方式：

• submit()

• execute()

其中，submit() 方法可以配合 Futrue 来接收线程执行的返回值，属于 ExecutorService 接口的方法；execute()无返回值。

任务拒绝策略

• AbortPolicy，终止策略，线程池会抛出异常并终止执行，它是默认的拒绝策略；

• CallerRunsPolicy，把任务交给当前线程来执行；

• DiscardPolicy，忽略此任务（最新的任务）；

• DiscardOldestPolicy，忽略最早的任务（最先加入队列的任务）。

• 自定义拒绝策略