【Android 异步操作】线程池 ( 线程池简介 | 线程池初始化方法 | 线程池种类 | AsyncTask 使用线程池示例 )

简介: 【Android 异步操作】线程池 ( 线程池简介 | 线程池初始化方法 | 线程池种类 | AsyncTask 使用线程池示例 )

文章目录

一、线程池简介

二、线程池初始化方法简介

三、线程池使用示例





一、线程池简介


线程池一般是实现了 ExecutorService 接口的类 , 一般使用 ThreadPoolExecutor 线程池 ;



线程池优势 :


减少线程对象个数 : 避免每次执行子线程任务时 , 都要执行 new Thread() 构造函数 , 避免每次创建一个新的对象 , 减少开销 ;


线程管理 : 方面对线程进行管理 , 已存在的线程直接重用 , 这样减少了线程对象创建的个数 , 降低了 CPU 资源开销 ;


控制并发数 : 每个 CPU 都有最合适的并发线程数 , 如果并发数过高 , 就会导致资源竞争 , 线程堵塞 , 合理控制并发数 , 能提高 CPU 使用效率 ;






二、线程池初始化方法简介


线程池初始化方法简介 :


newCachedThreadPool : 创建 可缓存线程池 ; 如果线程池长度超过处理需要 , 则回收线程 , 如果不能回收 , 就创建新线程 ;


newFixedThreadPool : 创建 定长线程池 ; 可以设置线程最大并发数 , 如果并发数已满 , 后续任务会在任务队列中等待 ;


newScheduledThreadPool : 创建 定长周期任务线程池 ; 该线程池支持周期性任务执行 ;


newSingleThreadExecutor : 创建 单线程化线程池 ; 该线程只有一个工作线程 , 可以保证所有任务按照指定的顺序执行 ; 如 FIFO 先进先出顺序 , 或 LIFO 后进先出顺序 ;






三、线程池使用示例


以 AsyncTask 源代码为例 , 在 SerialExecutor 中 , 最终使用的是 THREAD_POOL_EXECUTOR.execute(mActive) 执行线程任务 ; 线程池通过 execute 函数执行外部任务 ;


THREAD_POOL_EXECUTOR 是 自己配置的线程池 , 没有使用 Java 默认提供的四种线程池 , Java 提供的四种线程池是 可缓存线程池 , 定长线程池 , 定长周期任务线程池 , 单线程线程池 ;


THREAD_POOL_EXECUTOR 线程池配置代码如下 :


new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
            TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory,
            new ThreadPoolExecutor.DiscardOldestPolicy());



下面对 THREAD_POOL_EXECUTOR 自己配置的线程池参数进行说明解析 ,


CORE_POOL_SIZE 核心线程数 ,


MAXIMUM_POOL_SIZE 最大线程数 , 非核心线程就是二者相减 ,


KEEP_ALIVE 非核心线程闲置时间 , 超过一定时间非核心线程就会回收 ,


TimeUnit.SECONDS 非核心线程闲置时间单位 “秒” ,


sPoolWorkQueue 线程池任务队列 ,


sThreadFactory 线程工厂 , 作用是用于创建线程




线程池原理说明 :



线程池线程分类 : 线程池的线程分为 核心线程 , 非核心线程 两类 ;


非核心线程闲置时间 : 非核心线程 超过一定的闲置时间 , 就会被回收 ;



假设线程池最大线程数是 8 88 , 核心线程数 3 33 , 非核心线程数 5 55 ;



线程池任务队列 : 当启动一个线程池后 , 线程池会不停地从该任务队列中取出任务执行 ,


启动核心线程 : 如果当前核心线程没有满 , 小于 3 33 个 , 那么创建核心线程执行该任务 ,


启动非核心线程 : 如果当前核心线程已经有 3 33 个 , 但是 非核心线程没有满 , 小于 5 55 个 , 那么会创建非核心线程 , 执行该任务 ;



执行者 Executor 执行任务处理 : 如果核心线程数 有 3 33 个 , 非核心线程数有 5 55 个 , 最大线程数已满 ; 如果用户再提交任务给线程池 , 就会 将任务放入线程池任务队列中排队 ; 如果此时任务队列也满了 , 此时就会 抛出异常 ; 开发者应该通过回调处理被拒绝的任务 ;



线程池从任务队列取出任务并执行 : 线程数量 C CC


线程数量 C < 3 C < 3C<3 : 创建核心线程执行任务 ;

线程数量 3 ≤ C < 8 3 \leq C < 83≤C<8 : 创建非核心线程执行任务 ;


用户调用 Executor 的 execute 执行任务 : 线程数量 C CC


线程数 C = 8 C = 8C=8 , 任务队列没满 : 将任务放入任务队列 ;

线程数 C = 8 C = 8C=8 , 任务队列已满 : 会报出异常 , 使用 Handler 处理错误 ;



 

/**
     * 创建自定义线程池 , 用于并行执行任务 .
     */
    public static final Executor THREAD_POOL_EXECUTOR
            = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
            TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory,
            new ThreadPoolExecutor.DiscardOldestPolicy());
    /**
     * 一个 Executor 执行者 , 以串行顺序 , 一次执行一个任务 ; 针对特定进行 , 该序列化是全局的 , 
     * 即 一个进程只有一个该执行者 . 
     */
    public static final Executor SERIAL_EXECUTOR = Utils.hasHoneycomb() ? new SerialExecutor() :
            Executors.newSingleThreadExecutor(sThreadFactory);
    @TargetApi(11)
    private static class SerialExecutor implements Executor {
        final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();
        Runnable mActive;
        public synchronized void execute(final Runnable r) {
            mTasks.offer(new Runnable() {
                public void run() {
                    try {
                        r.run();
                    } finally {
                        scheduleNext();
                    }
                }
            });
            if (mActive == null) {
                scheduleNext();
            }
        }
        protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }
    }



目录
相关文章
|
6天前
|
Java
不自定义异步方法的线程池默认使用SimpleAsyncTaskExecutor
不自定义异步方法的线程池默认使用SimpleAsyncTaskExecutor
|
6天前
|
Java
线程池和线程详细教程
线程池和线程详细教程
|
8天前
|
监控 Java 调度
Java面试题:描述Java线程池的概念、用途及常见的线程池类型。介绍一下Java中的线程池有哪些优缺点
Java面试题:描述Java线程池的概念、用途及常见的线程池类型。介绍一下Java中的线程池有哪些优缺点
21 1
|
8天前
|
设计模式 存储 安全
Java面试题:设计一个线程安全的单例类并解释其内存占用情况?使用Java多线程工具类实现一个高效的线程池,并解释其背后的原理。结合观察者模式与Java并发框架,设计一个可扩展的事件处理系统
Java面试题:设计一个线程安全的单例类并解释其内存占用情况?使用Java多线程工具类实现一个高效的线程池,并解释其背后的原理。结合观察者模式与Java并发框架,设计一个可扩展的事件处理系统
21 1
|
8天前
|
设计模式 安全 Java
Java面试题:请解释Java中的线程池以及为什么要使用线程池?请解释Java中的内存模型以及如何避免内存泄漏?请解释Java中的并发工具包以及如何实现一个简单的线程安全队列?
Java面试题:请解释Java中的线程池以及为什么要使用线程池?请解释Java中的内存模型以及如何避免内存泄漏?请解释Java中的并发工具包以及如何实现一个简单的线程安全队列?
11 1
|
8天前
|
设计模式 缓存 安全
Java面试题:工厂模式与内存泄漏防范?线程安全与volatile关键字的适用性?并发集合与线程池管理问题
Java面试题:工厂模式与内存泄漏防范?线程安全与volatile关键字的适用性?并发集合与线程池管理问题
15 1
|
8天前
|
设计模式 并行计算 安全
Java面试题:如何使用设计模式优化多线程环境下的资源管理?Java内存模型与并发工具类的协同工作,描述ForkJoinPool的工作机制,并解释其在并行计算中的优势。如何根据任务特性调整线程池参数
Java面试题:如何使用设计模式优化多线程环境下的资源管理?Java内存模型与并发工具类的协同工作,描述ForkJoinPool的工作机制,并解释其在并行计算中的优势。如何根据任务特性调整线程池参数
13 0
|
8天前
|
安全 算法 Java
Java面试题:如何诊断和解决Java应用程序中的内存泄漏问题?如何实现一个线程安全的计数器?如何合理配置线程池以应对不同的业务场景?
Java面试题:如何诊断和解决Java应用程序中的内存泄漏问题?如何实现一个线程安全的计数器?如何合理配置线程池以应对不同的业务场景?
9 0
|
8天前
|
算法 安全 Java
Java面试题:解释JVM中的堆内存分代收集策略,并讨论年轻代和老年代的特点,描述Java中的线程池,并解释线程池的优点,解释Java中的`volatile`关键字的作用和使用场景
Java面试题:解释JVM中的堆内存分代收集策略,并讨论年轻代和老年代的特点,描述Java中的线程池,并解释线程池的优点,解释Java中的`volatile`关键字的作用和使用场景
12 0
|
8天前
|
设计模式 安全 Java
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
25 1