线程池

作者: 小蜗牛Aaron | 来源:发表于2020-01-24 20:16 被阅读0次

    为什么要使用线程池

    1、线程不仅java中是一个对象,每个线程都有自己的工作内存,线程创建、销毁需要时间,消耗性能 线程过多,会栈用很多内存
    2、操作系统需要频繁切换线程上下文(大家都想被运行),影响性能。
    3、如果创建时间+ 销毁时间 > 执行任务时间 就很不合算

    线程池原理

    1、线程池管理器,用于创建并管理线程池,包括创建线程池,销毁线程池,添加新任务;
    2、工作线程,线程池中线程,可以循环的执行任务,在没有任务时处于等待状态;
    3、任务接口:每个任务必须实现的接口,以供工作线程调度任务的执行,它主要规定了任务的 入口,任务执行完后的收尾工作,任务的执行状态等;
    4、任务队列:用于存放没有处理的任务。提供一种缓冲机制。


    image.png

    线程池 类层次结构

    image.png
    image.png

    线程池Api ScheduledExecutorService接口

    image.png

    ThreadPoolExecutor 典型使用

    image.png

    线程池原理 任务执行过程

    1、 是否达到到核心线程数量?没达到,创建一个工作线程来执行任务。
    2、 工作队列是否已满?没满,则将新提交的任务存储在工作队列里。
    3、 是否达到线程池最大数量?没达到,则创建一个新的工作线程来执行任务。
    4、 最后,执行拒绝策略来处理这个任务。


    image.png

    线程池API – Executors工具类

    你可以自己实例化线程池,也可以用Executors 创建线程池的工厂类,常用方法如下:

    1. newFixedThreadPool(int nThreads) 创建一个固定大小、任务队列容量无界的线程池。核心线程数=最大线程数。
    2. newCachedThreadPool() 创建的是一个大小无界的缓冲线程池。它的任务队列是一个同步队列。任务加入到池中,如果 池中有空闲线程,则用空闲线程执行,如无则创建新线程执行。池中的线程空闲超过60秒,将被销毁释放。线程数随任 务的多少变化。适用于执行耗时较小的异步任务。池的核心线程数=0 ,最大线程数= Integer.MAX_VALUE
    3. newSingleThreadExecutor() 只有一个线程来执行无界任务队列的单一线程池。该线程池确保任务按加入的顺序一个一 个依次执行。当唯一的线程因任务异常中止时,将创建一个新的线程来继续执行后续的任务。与newFixedThreadPool(1) 的区别在于,单一线程池的池大小在newSingleThreadExecutor方法中硬编码,不能再改变的。
    4. newScheduledThreadPool(int corePoolSize) 能定时执行任务的线程池。该池的核心线程数由参数指定,最大线程数= Integer.MAX_VALUE

    线程数量 如何确定合适数量的线程?

    计算型任务:cpu数量的1-2倍
    IO型任务:相对比计算型任务,需多一些线程,要根据具体的IO阻塞时长进行考量决定。 也可考虑根据需要在一个最小数量和最大数量间自动增减线程数。
    如tomcat中默认的最大线程数为:200

    相关文章

      网友评论

        本文标题:线程池

        本文链接:https://www.haomeiwen.com/subject/ppththtx.html