线程池使
java中经常需要用到多线程来处理一些业务,我们非常不建议单纯使用继承Thread或者实现Runnable接口的方式来创建线程,那样势必有创建及销毁线程耗费资源、线程上下文切换问题。同时创建过多的线程也可能引发资源耗尽的风险,这个时候引入线程池比较合理,方便线程任务的管理。java中涉及到线程池的相关类均在jdk1.5开始的java.util.concurrent包中,
涉及到的几个核心类及接口包括:
Executor、
Executors、
ExecutorService、
ThreadPoolExecutor、
FutureTask、
Callable、
Runnable等。
Executors工具类
创建线程池
| 方法名 | 功能 |
| new ThreadPool(int nThreads) | 创建固定大小的线程池 |
| newSingleThreadExecutor() | 创建只有一个线程的线程池 |
| newCachedThreadPool() | 创建一个不限线程数上限的线程池,任何提交的任务都将立即执行 |
线程池原理 拒绝策略
- AbortPolicy(默认拒绝策略)直接抛出异常
- CallerRunsPolicy 哪儿来的回哪儿去,那个线程让你来的由那个线程执行,反正我线程池是不执行
- CallerRunsPolicy
- DiscardOldestPolicy(弃老策略)
-
JDK 内置的拒绝策略如下:
1.AbortPolicy : 直接抛出异常,阻止系统正常运行。
2.CallerRunsPolicy : 只要线程池未关闭,该策略直接在调用者线程中,运行当前被丢弃的任务。显然这样做不会真的丢弃任务,但是,任务提交线程的性能极有可能会急剧下降。
3.DiscardPolicy : 该策略默默地丢弃无法处理的任务,不予任何处理。如果允许任务丢失,这是最好的一种方案。
4.DiscardOldestPolicy : 丢弃最老的一个请求,也就是即将被执行的一个任务,并尝试再次提交当前任务。
以上内置拒绝策略均实现了 RejectedExecutionHandler 接口,若以上策略仍无法满足实际需要,完全可以自己扩展 RejectedExecutionHandler 接口。



