Android开发中的线程池使用

忘是亡心i 2024-03-30 11:41 67阅读 0赞

## 一、前言 ##

既然Android中已经有了线程的概念，那么为什么需要使用线程池呢？我们从两个方面给出使用线程池的原因。

首先线程的新建和销毁都是存在性能上的消耗的，如果一个时间段有大量的网络请求，那么就需要多个线程的创建与销毁，性能上的损耗可想而知。

其次多个线程的存在也会占用CPU的执行时间段。我们知道如果只有一个CPU存在，那么线程的执行都是CPU轮流将执行时间分配给每一个线程。如果同时有多个子线程存在，那么相应的分配到主线程的CPU执行时间也会变少，这样App很大可能会出现卡顿现象。  
鉴于上述两方面的原因，我们引进来了线程池这样一个概念，线程的创建、调度、销毁等都是由线程池来管理，这样就可以做到线程的重用，不必每次都新建一个线程，减少了线程创建和销毁的性能损耗。同时线程池会限制创建线程的个数，让App中的线程个数保持在一个可控的范围，这样也可以控制多个线程抢占主线程的资源。

## 二、线程池的优点 ##

1.重用线程池中的线程，避免因为线程的创建和销毁所带来的性能开销。  
2.能有效控制线程池的最大并发数，避免大量的线程之间因互相抢占系统资源而导致的阻塞现象。  
3.能够对线程进行简单的管理，并提供定时执行以及指定间隔循环执行等功能。

## 三、ThreadPoolExecutor ##

Android中的线程池的概念来源于java中的Executor, Executor是一个接口,真正的线程池的实现为ThreadPoolExecutor. ThreadPoolExecutor提供了一系列参数来配置线程池,通过不同的参数可以创建不同类型的线程池.

ThreadPoolExecutor是线程池的真正实现,它的构造方法提供一系列参数来配置线程池.

我们来看看它的构造方法

源码路径: libcore/ojluni/src/main/java/java/util/concurrent/ThreadPoolExecutor.java

// Public constructors and methods
    
        /**
         * Creates a new {@code ThreadPoolExecutor} with the given initial
         * parameters and default thread factory and rejected execution handler.
         * It may be more convenient to use one of the {@link Executors} factory
         * methods instead of this general purpose constructor.
         *
         * @param corePoolSize the number of threads to keep in the pool, even
         *        if they are idle, unless {@code allowCoreThreadTimeOut} is set
         * @param maximumPoolSize the maximum number of threads to allow in the
         *        pool
         * @param keepAliveTime when the number of threads is greater than
         *        the core, this is the maximum time that excess idle threads
         *        will wait for new tasks before terminating.
         * @param unit the time unit for the {@code keepAliveTime} argument
         * @param workQueue the queue to use for holding tasks before they are
         *        executed.  This queue will hold only the {@code Runnable}
         *        tasks submitted by the {@code execute} method.
         * @throws IllegalArgumentException if one of the following holds:<br>
         *         {@code corePoolSize < 0}<br>
         *         {@code keepAliveTime < 0}<br>
         *         {@code maximumPoolSize <= 0}<br>
         *         {@code maximumPoolSize < corePoolSize}
         * @throws NullPointerException if {@code workQueue} is null
         */
        public ThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  TimeUnit unit,
                                  BlockingQueue<Runnable> workQueue) {
            this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
                 Executors.defaultThreadFactory(), defaultHandler);
        }

对应的参数说明:

![e0e3a56f846a5761e382d31e46d49d82.jpeg][]

## 四、线程池分类 ##

定义的源码路径为: /libcore/ojluni/src/main/java/java/util/concurrent/Executors.java

根据参数的不同配置，Java内置了4种常用线程池：

*  定长线程池（FixedThreadPool） 调用Executors.newFixedThreadPool()创建
 *  定时线程池（ScheduledThreadPool ）调用Executors.newScheduledThreadPool()创建
 *  缓存线程池（CachedThreadPool）调用Executors.newCachedThreadPool()创建
 *  单例线程池（SingleThreadExecutor）调用Executors.newSingleThreadExecutor()创建

特点和对比图

![5de9c5de658a57eb1ba8ac602343c7ad.jpeg][]

总结的思维导图:

![c61e871e7bbe276b1f5695c740e67b2a.jpeg][]

## 五、使用方法 ##

// 1. 创建线程池
       // 创建时，通过配置线程池的参数，从而实现自己所需的线程池
       Executor threadPool = new ThreadPoolExecutor(
                                                  CORE_POOL_SIZE,
                                                  MAXIMUM_POOL_SIZE,
                                                  KEEP_ALIVE,
                                                  TimeUnit.SECONDS,
                                                  sPoolWorkQueue,
                                                  sThreadFactory
                                                  );
        // 注：在Java中，已内置4种常见线程池
    
    // 2. 向线程池提交任务：execute（）
        // 说明：传入 Runnable对象
           threadPool.execute(new Runnable() {
                @Override
                public void run() {
                    ... // 线程执行任务
                }
            });
    
    // 3. 关闭线程池shutdown() 
      threadPool.shutdown();
      
      // 关闭线程的原理
      // a. 遍历线程池中的所有工作线程
      // b. 逐个调用线程的interrupt（）中断线程（注：无法响应中断的任务可能永远无法终止）
    
      // 也可调用shutdownNow（）关闭线程：threadPool.shutdownNow（）
      // 二者区别：
      // shutdown：设置 线程池的状态 为 SHUTDOWN，然后中断所有没有正在执行任务的线程
      // shutdownNow：设置 线程池的状态 为 STOP，然后尝试停止所有的正在执行或暂停任务的线程，并返回等待执行任务的列表
      // 使用建议：一般调用shutdown（）关闭线程池；若任务不一定要执行完，则调用shutdownNow（）

## 六、Demo ##

我们通过源码来看下是怎么使用的:

源码片段:

/Dialer/java/com/android/voicemail/impl/transcribe/TranscriptionService.java

1. 创建一个单例线程池

private ExecutorService getExecutorService() {
        if (executorService == null) {
          // The common use case is transcribing a single voicemail so just use a single thread executor
          // The reason we're not using DialerExecutor here is because the transcription task can be
          // very long running (ie. multiple minutes).
          executorService = Executors.newSingleThreadExecutor();
        }
        return executorService;
      }

2. 调用 execute(Runnable runnable)方法,执行任务

activeTask =
              configProvider.shouldUseSyncApi()
                  ? new TranscriptionTaskSync(
                      this, new Callback(), workItem, getClientFactory(), configProvider)
                  : new TranscriptionTaskAsync(
                      this, new Callback(), workItem, getClientFactory(), configProvider);
        //执行任务
        getExecutorService().execute(activeTask);

3. 任务执行完毕后,调用shutdown方法

@Override
      @MainThread
      public void onDestroy() {
        if (executorService != null) {
          executorService.shutdownNow();
          executorService = null;
        }
      }

[e0e3a56f846a5761e382d31e46d49d82.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/aaabe4caad6f45cab6da86866c8a72f8.jpeg
[5de9c5de658a57eb1ba8ac602343c7ad.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/16b67ad3942e47f7835a5fe3d2e8dcaa.jpeg
[c61e871e7bbe276b1f5695c740e67b2a.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/31ef998c95da4ed18d7a07e38fef90c3.jpeg