根据需要扩展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的执行流程

正常情况下的,threadPoolExecutor的执行流程是:

1、线程数量低于core_size,不断的创建新的线程;
2core_size已达到,将任务扔到队列里面;
3core_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,则会大量创建新线程。(理论上,上线前的压测会有所改动)。

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

流程实现代码:https://github.com/li-shaoke/ExpandThreadPool

 

参考自:

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

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

    原文作者:Eric-Lee
    原文地址: https://www.cnblogs.com/ericli-ericli/p/8117670.html
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞