一篇简短文章搞定java线程池
2018-03-08 11:33
579 查看
我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题:如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为线程的创建和销毁是比较耗费系统资源的。 在Java中可以通过线程池来解决上述的问题。今天先来讲解下最核心的ThreadPoolExecutor线程池类,最后通过一个流程图彻底了解ThreadPoolExecutor线程池。 通过ThreadPoolExecutor创建线程池,那么API是:public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue);
那么重点就是理解好这几个参数(大致浏览下,主要是看明白下面的图):corePoolSize:核心池的大小。在创建了线程池后,默认情况下,线程池中并没有任何线程,而是等待有任务到来才创建线程去执行任务,除非调用了prestartAllCoreThreads()或者prestartCoreThread()方法,从这2个方法的名字就可以看出,是预创建线程的意思,即在没有任务到来之前就创建corePoolSize个线程或者一个线程。默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中;
maximumPoolSize:线程池最大线程数,这个参数也是一个非常重要的参数,它表示在线程池中最多能创建多少个线程;
keepAliveTime:表示线程没有任务执行时最多保持多久时间会终止。默认情况下,只有当线程池中的线程数大于corePoolSize时,keepAliveTime才会起作用,直到线程池中的线程数不大于corePoolSize,即当线程池中的线程数大于corePoolSize时,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程数不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法,在线程池中的线程数不大于corePoolSize时,keepAliveTime参数也会起作用,直到线程池中的线程数为0;
unit:参数keepAliveTime的时间单位
workQueue:一个阻塞队列,用来存储等待执行的任务,这个参数的选择也很重要,会对线程池的运行过程产生重大影响,一般来说,这里的阻塞队列有以下几种选择: ArrayBlockingQueue;
LinkedBlockingQueue; SynchronousQueue; 6.threadFactory:线程工厂,主要用来创建线程;7.handler:表示当拒绝处理任务时的策略,有以下四种取值:ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
ThreadPoolExecutor.CallerRunsPolicy:由调用线程处理该任务
大致了解了上面参数后,兴许还有点模糊,不能明确理解其中的含义,这个流程图将彻底帮你搞清楚参数之间的关系:
看明白图了,再去看下上面的参数解释,是不是更清楚了。 搞清楚了ThreadPoolExecutor在去理解Executors提供的四中线程池就比较简单了,核心差别只是在这四类线程池内部给你设定好了这几个参数而已。核心是理解参数之间相互影响的关系。
关注公众号:
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue);
那么重点就是理解好这几个参数(大致浏览下,主要是看明白下面的图):corePoolSize:核心池的大小。在创建了线程池后,默认情况下,线程池中并没有任何线程,而是等待有任务到来才创建线程去执行任务,除非调用了prestartAllCoreThreads()或者prestartCoreThread()方法,从这2个方法的名字就可以看出,是预创建线程的意思,即在没有任务到来之前就创建corePoolSize个线程或者一个线程。默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中;
maximumPoolSize:线程池最大线程数,这个参数也是一个非常重要的参数,它表示在线程池中最多能创建多少个线程;
keepAliveTime:表示线程没有任务执行时最多保持多久时间会终止。默认情况下,只有当线程池中的线程数大于corePoolSize时,keepAliveTime才会起作用,直到线程池中的线程数不大于corePoolSize,即当线程池中的线程数大于corePoolSize时,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程数不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法,在线程池中的线程数不大于corePoolSize时,keepAliveTime参数也会起作用,直到线程池中的线程数为0;
unit:参数keepAliveTime的时间单位
workQueue:一个阻塞队列,用来存储等待执行的任务,这个参数的选择也很重要,会对线程池的运行过程产生重大影响,一般来说,这里的阻塞队列有以下几种选择: ArrayBlockingQueue;
LinkedBlockingQueue; SynchronousQueue; 6.threadFactory:线程工厂,主要用来创建线程;7.handler:表示当拒绝处理任务时的策略,有以下四种取值:ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
ThreadPoolExecutor.CallerRunsPolicy:由调用线程处理该任务
大致了解了上面参数后,兴许还有点模糊,不能明确理解其中的含义,这个流程图将彻底帮你搞清楚参数之间的关系:
看明白图了,再去看下上面的参数解释,是不是更清楚了。 搞清楚了ThreadPoolExecutor在去理解Executors提供的四中线程池就比较简单了,核心差别只是在这四类线程池内部给你设定好了这几个参数而已。核心是理解参数之间相互影响的关系。
关注公众号:
相关文章推荐
- 一篇文章搞定面试中的二叉树题目(java实现)
- 一篇文章搞定Java工厂模式
- 一篇文章搞定面试中的二叉树题目(java实现)
- 一篇文章搞定面试中的链表题目(java实现)
- 介绍一篇关于session的好文章,写的很详细(jsp-servlet 技术)----(转贴自JavaResearch)
- 【java】统计一篇英文文章每个字母出现的次数
- 万能的林萧说:一篇文章教会你,如何做到招聘要求中的“要有扎实的Java基础”。
- java速成----一篇博文搞定基础
- [转]一篇文章搞定SqlDataAdapter
- 一篇不错的讲解Java异常的文章(转载)----感觉很不错,读了以后很有启发
- Android NDK开发之旅(2):一篇文章搞定Android Studio中使用CMake进行NDK/JNI开发
- 转载老师的一篇文章——java自学之路
- java统计一篇文章中单词出现的次数
- 转载一篇写的不错的java ClassLoader工作机制的文章
- 对我很有帮助的一篇关于“扩展 Eclipse 的 Java 开发工具”的文章
- 转:Java 动态代理的内部实现机制(大体意思正确,写的还行的一篇文章)
- 一篇文章轻松搞定功能测试
- JAVA 线程池讲解文章
- 一篇不错的讲解Java异常的文章(转载)
- 数据库的原理,一篇文章搞定(二)