文章目录
一、线程池作用
二、线程池种类
三、线程池工作机制
四、线程池任务调度源码解析
一、线程池作用
线程池作用 :
① 避免创建线程 : 避免每次使用线程时 , 都需要 创建线程对象 ;
② 统一管理 : 统一管理线程 , 重用存在的线程 , 减少线程对象创建 , 销毁的开销 ;
③ 控制并发 : 可 控制线程的最大并发数 , 提高资源使用效率 , 避免资源竞争导致堵塞 ;
二、线程池种类
线程池种类 :
① newCachedThreadPool : 可缓存线程池 , 如果 线程池线程个数已满 , 回收空闲线程 , 如果没有空闲线程 , 此时会创建新线程 ;
② newFixedThreadPool : 创建固定大小线程池 , 可设置并发数 , 如果并发数已满 , 后续任务会 在 等待队列 中等待可用线程 ;
③ newScheduledThreadPool : 创建固定大小线程池 , 其支持 周期性任务 ;
④ newSingleThreadExecutor : 创建 单线程 线程池 , 该线程池中 只有一个线程 , 所有的任务按照指定的优先级顺序执行 , 如 FIFO 先入先出 ( 先到的先执行 , 后到的后执行 ) , LIFO 后入先出 ( 后到的先执行 ) ;
三、线程池工作机制
线程池线程相关概念:
线程数 : 线程池的 有 最大线程数 MaxSzie , 核心线程数 CoreSize , 非核心线程数就是 MaxSize - CoreSize ;
示例 : 最大线程数 ( MaxSize ) 是 8 个 , 有 3 个核心线程 ( CoreSize ) , 5 个非核心线程 ;
非核心线程 : 闲置超过一定时间 , 就会被回收 ;
线程池任务调度 : 线程池中维护了一个任务队列 , 线程池启动后 , 会不停的从任务队列中取出任务 , 如果有新任务 , 执行如下操作 ;
如果 线程数 小于核心线程数 ( CoreSize ) , 那么创建核心线程 , 执行上述任务 ;
如果 线程数 大于核心线程数 ( CoreSize ) , 小于最大线程数 ( MaxSize ) , 那么创建非核心线程 , 执行上述任务 ;
如果 线程数 超过 最大线程数 ( MaxSize )
如果 任务队列没满 , 则将任务放入任务队列 ;
如果 任务队列满了 , 则抛出异常 ; 这里一般情况下需要手动处理这种情况 , 任务拒绝后 , 处理善后 ;
四、线程池任务调度源码解析
在 AsyncTask.java 中 , 在静态代码块中 , 自己 自定义创建了线程池 , 没有使用上述四种线程池 ;
创建线程池时传入的参数 :
CORE_POOL_SIZE : 核心线程数
MAXIMUM_POOL_SIZE : 最大线程数
KEEP_ALIVE_SECONDS : 闲置时间 , 非核心线程一旦闲置超过一定时间 , 就会被回收
TimeUnit.SECONDS : 闲置时间单位 , 秒
sPoolWorkQueue : 线程队列 , 任务队列
sThreadFactory : 线程工厂 , 用于生产线程
public abstract class AsyncTask<Params, Progress, Result> { static { /** * 自定义的线程池 : * CORE_POOL_SIZE : 核心线程数 * MAXIMUM_POOL_SIZE : 最大线程数 * KEEP_ALIVE_SECONDS : 闲置时间 , 非核心线程一旦闲置超过一定时间 , 就会被回收 * TimeUnit.SECONDS : 闲置时间单位 , 秒 * sPoolWorkQueue : 线程队列 , 任务队列 * sThreadFactory : 线程工厂 , 用于生产线程 */ ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor( CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory); threadPoolExecutor.allowCoreThreadTimeOut(true); THREAD_POOL_EXECUTOR = threadPoolExecutor; } private static class SerialExecutor implements Executor { protected synchronized void scheduleNext() { if ((mActive = mTasks.poll()) != null) { // 线程池执行任务 THREAD_POOL_EXECUTOR.execute(mActive); } } } }
在 AsyncTask 中 , 调用 ThreadPoolExecutor THREAD_POOL_EXECUTOR 线程池的 void execute(Runnable command) 方法 , 执行线程池任务 ;
在 execute 方法中, 需要执行以下三个步骤 :
如果当前 运行线程数小于核心线程数 , 尝试 启动新线程执行该任务, 该任务是线程的第一个任务.调用 addWorker 方法会检查运行状态, 和线程运行个数, 避免在不应该添加线程时执行错误操作.
如果 任务成功加入队列, 需要 双重检查 ( 进入该方法后, 线程池可能关闭 ), 在进入该方法后, 是否添加了一个线程, 或者线程池是否关闭. 因此, 我们应该再次检查运行状态, 如果需要, 将任务放回队列中, 或者启动一个新线程.
如果 不能将任务入队, 尽量添加一个新线程. 如果添加失败, 此时线程池可能关闭, 或者运行线程数等于最大线程数, 需要拒绝该任务.
public class ThreadPoolExecutor extends AbstractExecutorService { /** * 在将来的某个时间执行给定的任务. * 该任务可能在一个新线程中执行, 也可能在当前线程池中已存在的线程中执行. * * 如果任务不能被提交执行, 或该线程池失效, 或该线程池线程个数由于超过最大线程数, * 任务被 RejectedExecutionHandler 处理. * * @param command 向线程池中提交的任务 * @throws RejectedExecutionException 如果任务不能被接受, 抛出该异常 * @throws NullPointerException 如果任务为空, 抛出该异常 */ public void execute(Runnable command) { if (command == null) throw new NullPointerException(); /* * 三个步骤: * * 1. 如果当前运行线程数小于核心线程数 , 尝试启动新线程执行该任务, 该任务是线程的第一个任务. * 调用 addWorker 方法会检查运行状态, 和线程运行个数, 避免在不应该添加线程时执行错误操作. * * 2. 如果任务成功加入队列, 需要双重检查 ( 进入该方法后, 线程池可能关闭 ), * 在进入该方法后, 是否添加了一个线程, 或者线程池是否关闭. * 因此, 我们应该再次检查运行状态, 如果需要, 将任务放回队列中, 或者启动一个新线程. * * 3. 如果不能将任务入队, 尽量添加一个新线程. * 如果添加失败, 此时线程池可能关闭, 或者运行线程数等于最大线程数, 需要拒绝该任务. */ int c = ctl.get(); // 当前运行的线程数 小于 核心线程数 if (workerCountOf(c) < corePoolSize) { if (addWorker(command, true)) return; c = ctl.get(); } // 确保处于运行状态, 然后将任务添加到队列中 if (isRunning(c) && workQueue.offer(command)) { int recheck = ctl.get(); // 如果不处于运行状态, 从队列中移除 if (! isRunning(recheck) && remove(command)) reject(command); // 拒绝任务 else if (workerCountOf(recheck) == 0) addWorker(null, false); } // 尝试添加任务 else if (!addWorker(command, false)) reject(command); } }