根据需要扩展java中的ThreadPoolExecutor

ThreadPoolExecutor是可扩展的，通过查看源码可以发现，它提供了几个可以在子类化中改写的方法：beforeExecute,afterExecute,terminated.

protected void beforeExecute(Thread t, Runnable r) { }
protected void afterExecute(Runnable r, Throwable t) { }
protected void terminated() { }

在执行任务的线程中将调用beforeExecute和afterExecute等方法，在这些方法中还可以添加日志、计时、监视或者统计信息收集的功能。

无论任务是从run中正常返回，还是抛出一个异常而返回，afterExecute都会被调用。

如果任务在完成后带有一个Error，那么就不会调用afterExecute。

如果beforeExecute抛出一个RuntimeException，那么任务将不被执行，并且afterExecute也不会被调用。

在线程池完成关闭时调用terminated，也就是在所有任务都已经完成并且所有工作者线程也已经关闭后，terminated可以用来释放Executor在其生命周期里分配的各种资源，此外还可以执行发送通知、记录日志或者手机finalize统计等操作。

正常情况下的，threadPoolExecutor的执行流程是：

1、线程数量低于core_size,不断的创建新的线程;
2、core_size已达到,将任务扔到队列里面;
3、core_size已达到，队列已经满了(插入任务失败),开始创建新线程；
4、线程数到max_size后，如果队列还是满的,抛出 RejectedExecutionException

这种执行过程，存在一个弊端：

1、当前线程数，超过core_size，会立刻将任务添加到队列中。如果队列设置的非常长,任务又很多的情况下，将会有频繁的任务入队和出队的操作。这种操作也是有一定资源及性能消耗的（理论上，作者未进行真机验证，网上有网友也指出过这个问题）。

2、线程数只有将 core_size和队列数量占满的情况下，才启用新的线程（一直开到最大数量）。如果机器性能好，而core_size值设的小，会有资源浪费。

网上有人提出，设置新的执行流程：

1、未满core_size，不创建新的线程；
2、未满max，且core_size无空闲，创建新线程；
3、达到max，且全部无空闲,将任务丢进队列
4、达到max,且达到队列数，再抛出 RejectedExecutionException

这种也存在一种问题：

如果 core_size 远小于 max_size，则会大量创建新线程。（理论上，上线前的压测会有所改动）。

不过，如果项目存在瞬时大流出量，这种流程，则是一种不错的处理方案。

参考自：

http://blog.sina.com.cn/s/blog_6145ed8101015xfg.html

http://blog.csdn.net/linsongbin1/article/details/78275283

秒客网