首先了解线程池的体系

线程池的体系.png

线程池的内部结构

线程池内部结构.png

线程的创建需要申请虚拟机栈,本地方法区,程序计数器等线程私有的内存空间
再线程销毁时需要回收这些内存资源,所以再线程频繁创建和销毁的时候会消耗大量的资源,所以就引入了线程池,为了复用已经创建好的线程

线程池主要解决两个问题

1.当执行大量的异步任务时线程可以提供很好的性能
2.线程池提供了一种资源限制和管理手段,比如可以限制线程的个数,动态新增线程等

线程池的创建

1.Executors工厂方法创建,提供多个静态方法用于创建不同类型的线程池

Executors.newSingleThreadExecutor()创建单个线程的线程池
Executors.newCachedThreadExecutor()创建可以缓存的线程池
Executors.newFixedThreadExecutor(int size)创建固定数量并可以重用的的线程池
Executors.newSchedledThreadExecutor(int size)创建固定数量可以周期性执行的线程池,可以执行循环任务,调用scheduleAtFixedRate()执行周期任务

2.ThreadPoolExecutor创建

new ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler
)

corePoolSize:核心线程数
maximumPoolSize:最大线程数
keepAliveTime:再超出核心线程的时候,多余的线程再销毁之前等待的时间
unit:上面等待时间的单位
workQueue:保存任务的任务队列
threadFactory:在创建线程时使用的工厂
handler:在线程队列存放不了,和已经到了最大线程数的时候使用handler处理,如果不指定,达到线程数量边界的时候会抛出异常(一般不会出现这种情况)

提交线程到线程池的流程(工作流程)

当执行submit()或execute()提交一个任务时

1)当线程池的数量还没有到达核心线程(corePoolSize)数的大小时,线程池会创建一个线程来执行提交的任务,无论当前线程是否处于空闲状态
2)当前线程池的线程数量已经达到corePoolSize大小时,线程池会把任务加入到队列中,直到某个线程空闲时,线程池会根据线程队列的规则,取出一个新的任务执行
3)如果线程池中的线程数大于corePoolSize时,但还没有达到最大线程数(maximumPoolSize),并且等待队列已经满了,就会创建新的线程去执行任务
4)如果提交的任务无法被核心线程执行,又无法加入到等待队列中,又无法创建新的线程(非核心线程)执行,线程池会根据传入的拒绝处理器(handler)去处理这个任务, 如果没有传处理器就会抛出一程,线程池拒绝处理

阿里Java开发手册中禁止使用Executors的

特别是newFixedThreadExecutor()和newSingleThreadExecutor()创建线程池
newFixedThreadExecutor()和newSingleThreadExecutor()源码中默认出入new LinkedBlockingQueue<Runnable>(),而LinkedBlockingQueue中默认使用Integer.MAX_VALUE作为队列的最大容量,在核心线程执行时间很长时,一直在向队形中添加任务就会出现OOM
newCachedThreadExecutor()创建线程池时,非核心线程默认使用的Integer.MAX_VALUE

参考Android 工程师进阶 34 讲