一张图看懂线程池原理

先把想说的话说在前面

Java的线程池在设计上我觉得特别牛,其中最大的是能把两个甚至多个看上去原理不太相同的线程池类型,在不用if/else的语句的情况下,用相同的代码实现了

线程池的定义及分类

线程池顾名思义就是线程的集合的管理者,线程池可以对集合里面的线程进行增删查改等操作,Java中提供的线程池有如下几个,

  • newSingleThreadExecutor
  • newScheduleThreadPool
  • newSingleThreadScheduledExecutor
  • newCachedThreadPool
  • newFixedThreadPool
    这几类线程池的类型都是通过参数(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit, BlockingQueue<Runnable> workQueue)确定的。下面我们会用一张图来解释里面最重要的两个线程池一个是newCachedThreadPool,另一个是newFixedThreadPool,然后反向说明构造对应的线程池,这几个参数应该怎么取值。

线程池原理

  • newFixedThreadPool原理

    newFixedThreadPool原理解释图.png

    从图中可以看到newFixedThreadPool类型的处理任务的过程,当任务到来时,逻辑处理过程如下:
    newFixedThreadPool逻辑处理图

    通过上诉逻辑图我们可知,corePoolSize>0;maximumPoolSize>=0;keepAliveTime >= 0,workQueue需要是LinkedBlockingQueue对象;

  • newCachedThreadPool原理图

    image.png

    分析上图可知,corePoolSize=0因为其中么有corePoolSize的概念,maximumPoolSize>0因为需要有线程来处理,keepAliveTime > 0因为需要线程复用,如果等于0,则每次都会新建线程了。而最重要的workQueue的类型是SynchronousQueue,因为此线程池的实现需要有一个无缓冲的队列性质,简单来讲就是下一个任务到来时,会把前一个任务挤出去。

或许可以总结这样一段话

newFixedThreadPool利用可缓冲的队列去等待无存活时长的线程执行结束以实现线程复用,newCachedThreadPool利用无缓冲的队列SynchronousQueuepoll函数去实现具有存活时间的线程以实现线程复用。所以根据他们两的特点,newFixedThreadPool的优势在于可以执行大量的连续的耗时任务操作,而newCachedThreadPool对大量的耗时任务操作是没有优势的,原因在于,newCachedThreadPool对于大量的任务到来会导致线程数量急速膨胀,而newFixedThreadPool却可以将任务缓冲到队列中。newCachedThreadPool适合短平慢的业务。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容