先把想说的话说在前面
Java的线程池在设计上我觉得特别牛,其中最大的是能把两个甚至多个看上去原理不太相同的线程池类型,在不用if/else的语句的情况下,用相同的代码实现了
线程池的定义及分类
线程池顾名思义就是线程的集合的管理者,线程池可以对集合里面的线程进行增删查改等操作,Java中提供的线程池有如下几个,
- newSingleThreadExecutor
- newScheduleThreadPool
- newSingleThreadScheduledExecutor
- newCachedThreadPool
- newFixedThreadPool
这几类线程池的类型都是通过参数(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit, BlockingQueue<Runnable> workQueue)
确定的。下面我们会用一张图来解释里面最重要的两个线程池一个是newCachedThreadPool
,另一个是newFixedThreadPool
,然后反向说明构造对应的线程池,这几个参数应该怎么取值。
线程池原理
-
newFixedThreadPool原理
从图中可以看到newFixedThreadPool类型的处理任务的过程,当任务到来时,逻辑处理过程如下:
通过上诉逻辑图我们可知,corePoolSize>0;maximumPoolSize>=0;keepAliveTime >= 0,workQueue需要是LinkedBlockingQueue对象
; -
newCachedThreadPool原理图
分析上图可知,corePoolSize=0
因为其中么有corePoolSize的概念,maximumPoolSize>0
因为需要有线程来处理,keepAliveTime > 0
因为需要线程复用,如果等于0,则每次都会新建线程了。而最重要的workQueue
的类型是SynchronousQueue
,因为此线程池的实现需要有一个无缓冲的队列性质,简单来讲就是下一个任务到来时,会把前一个任务挤出去。
或许可以总结这样一段话
newFixedThreadPool利用可缓冲的队列去等待无存活时长的线程执行结束以实现线程复用,newCachedThreadPool利用无缓冲的队列
SynchronousQueue
的poll
函数去实现具有存活时间的线程以实现线程复用。所以根据他们两的特点,newFixedThreadPool的优势在于可以执行大量的连续的耗时任务操作,而newCachedThreadPool对大量的耗时任务操作是没有优势的,原因在于,newCachedThreadPool对于大量的任务到来会导致线程数量急速膨胀,而newFixedThreadPool却可以将任务缓冲到队列中。newCachedThreadPool适合短平慢的业务。