摘要：線程池根據(jù)當(dāng)前在系統(tǒng)中運(yùn)行的進(jìn)程來(lái)優(yōu)化線程片。線程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線程數(shù)量限制問(wèn)題。線程池中允許的線程最大數(shù)量，當(dāng)活動(dòng)線程達(dá)到這個(gè)數(shù)值后，后續(xù)的新任務(wù)會(huì)被阻塞。

每個(gè) Android 應(yīng)用進(jìn)程在創(chuàng)建時(shí)，會(huì)同時(shí)創(chuàng)建一個(gè)線程，我們稱之為主線程，負(fù)責(zé)更新 UI 界面以及和處理用戶之間的交互，因此，在 Android 中，我們又稱之為 UI 線程。一個(gè)進(jìn)程中 UI 線程只有一個(gè)，為了不造成界面卡頓、提高用戶體驗(yàn)，我們勢(shì)必要將一些耗時(shí)操作交由子線程來(lái)執(zhí)行。

使用子線程的方式主要分兩種：

直接使用 Thread 和 Runnable 等創(chuàng)建子并使用線程

使用線程池創(chuàng)建并使用子線程

線程池是什么

線程池是指在初始化一個(gè)多線程應(yīng)用程序過(guò)程中創(chuàng)建一個(gè)線程集合，然后在需要執(zhí)行新的任務(wù)時(shí)重用這些線程而不是新創(chuàng)建一個(gè)線程。線程池中線程的數(shù)量通常完全取決于可用內(nèi)存數(shù)量和應(yīng)用程序的需求；每個(gè)線程都有被分配一個(gè)任務(wù)，一旦任務(wù)完成了，線程回到池子中并等待下一次分配任務(wù)。

一般情況下，推薦使用線程池來(lái)創(chuàng)建和使用子線程，不建議使用第一種方式。

上面說(shuō)了，在 Android 開(kāi)發(fā)過(guò)程中，建議使用線程池來(lái)創(chuàng)建和使用子線程，那么使用線程池的好處有哪些呢？

線程池改進(jìn)了一個(gè)應(yīng)用程序的響應(yīng)時(shí)間。由于線程池中的線程已經(jīng)準(zhǔn)備好且等待被分配任務(wù)，應(yīng)用程序可以直接拿來(lái)使用而不用新建一個(gè)線程。

線程池節(jié)省了 CLR 為每個(gè)短生存周期任務(wù)創(chuàng)建一個(gè)完整的線程開(kāi)銷并可以在任務(wù)完成后回收資源。

線程池根據(jù)當(dāng)前在系統(tǒng)中運(yùn)行的進(jìn)程來(lái)優(yōu)化線程片。

線程池允許我們開(kāi)啟多個(gè)任務(wù)而不用為每個(gè)線程設(shè)置屬性。

線程池允許我們?yōu)檎趫?zhí)行的任務(wù)的程序參數(shù)傳遞一個(gè)包含狀態(tài)信息的對(duì)象引用。

線程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線程數(shù)量限制問(wèn)題。

系統(tǒng)分配給每個(gè)應(yīng)用的線程棧是固定的，使用線程池可以有效地避免線程棧溢出引起的應(yīng)用崩潰。

Android 中線程池的真正實(shí)現(xiàn)是 ThreadPoolExecutor，其構(gòu)造方法有 5 個(gè)，通過(guò)一系列參數(shù)來(lái)配置線程池。下面介紹一個(gè)比較常用的構(gòu)造方法及其參數(shù)的含義。

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue workQueue,
                          ThreadFactory threadFactory)

ThreadPoolExecutor 執(zhí)行任務(wù)時(shí)大致遵循如下規(guī)則：

如果線程池中的線程數(shù)量未達(dá)到核心線程的數(shù)量，那么會(huì)直接啟動(dòng)一個(gè)核心線程來(lái)執(zhí)行任務(wù)。

如果線程池中的線程數(shù)量已經(jīng)達(dá)到或超過(guò)核心線程的數(shù)量，那么任務(wù)會(huì)被插入到任務(wù)隊(duì)列中等待執(zhí)行。

如果步驟 2 中無(wú)法將任務(wù)插入到任務(wù)隊(duì)列，則表示任務(wù)隊(duì)列已滿。此時(shí)，如果線程數(shù)量未達(dá)到 maximumPoolSize 值，則會(huì)立即啟動(dòng)一個(gè)非核心線程來(lái)執(zhí)行任務(wù)。

如果步驟 3 中線程數(shù)量大于或等于 maximumPoolSize 值，則拒絕執(zhí)行次任務(wù)，此時(shí) ThreadPoolExecutor 會(huì)調(diào)用 RejectedExecutionHandler 的 rejectedExecution 來(lái)通知調(diào)用者。

RejectedExecutionHandler 是線程池持有的一個(gè)對(duì)象，用于不能由 ThreadPoolExecutor 執(zhí)行的任務(wù)的處理

Android 中最常見(jiàn)線程池有四種，分別是：FixedThreadPool、CacheThreadPool、ScheduledThreadPool 以及 SingleThreadPool，它們都直接或間接的通過(guò)配置 ThreadPoolExecutor 來(lái)實(shí)現(xiàn)自己的功能特性。

線程數(shù)量固定的線程池，通過(guò) Executors 的 newFixedThreadPool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法：

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue());
}

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue(),
                                  threadFactory);
}

除非線程池被關(guān)閉，否則線程不會(huì)被回收，即時(shí)線程處于空閑狀態(tài)。如果在所有線程都處于活動(dòng)狀態(tài)時(shí)提交額外的任務(wù)，它們將在隊(duì)列中等待，直到有一個(gè)線程可用為止。由創(chuàng)建方法可知，F(xiàn)ixedThreadPool 只有核心線程并且這個(gè)核心線程沒(méi)有超時(shí)機(jī)制（keepAliveTime 參數(shù)為 0L），加上線程不會(huì)被回收，因此使用此類線程池可以快速地響應(yīng)外界的請(qǐng)求。

線程數(shù)量不定的線程池，通過(guò) Executors 的 newCachedThreadPool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法：

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(/* corePoolSize*/ 0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue());
}

public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {
    return new ThreadPoolExecutor(/* corePoolSize*/ 0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue(),
                                  threadFactory);
}

CacheThreadPool 有以下個(gè)特征：

沒(méi)有核心線程（ corePoolSize 參數(shù)為 0 ），只有非核心線程且非核心線程的數(shù)量為 Integer.MAX_VALUE，這就相當(dāng)于非核心線程的數(shù)量可以無(wú)限大。

線程池的線程處于空閑狀態(tài)時(shí)，線程池會(huì)重用空閑的線程來(lái)處理新任務(wù)，否則創(chuàng)建新的線程來(lái)處理，新創(chuàng)建的線程會(huì)添加到線程池中。這將提高執(zhí)行許多短期異步任務(wù)的程序性能。

閑置時(shí)間超過(guò) 60 秒的空閑線程會(huì)被回收（keepAliveTime 參數(shù)為 60L ）。因此，閑置時(shí)間足夠長(zhǎng)的 CacheThreadPool 也不會(huì)消耗任何系統(tǒng)資源。

核心線程數(shù)量固定，非核心線程數(shù)量不定的線程池，通過(guò) Executors 的 newscheduledthreadpool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法：

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
    return new ScheduledThreadPoolExecutor(corePoolSize);
}

public static ScheduledExecutorService newScheduledThreadPool(
        int corePoolSize, ThreadFactory threadFactory) {
    return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
}

ScheduledThreadPool 相比較其他三種線程池，有特殊性，由 ScheduledThreadPoolExecutor 實(shí)現(xiàn)， newscheduledthreadpool 方法也是通過(guò)創(chuàng)建 ScheduledThreadPoolExecutor 的實(shí)例來(lái)完成線程池的創(chuàng)建，代碼如下：

public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE,
          DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS,
          new DelayedWorkQueue());
}

public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory) {    super(corePoolSize, Integer.MAX_VALUE,
          DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS,
          new DelayedWorkQueue(), threadFactory);
}

由 ScheduledThreadPoolExecutor 的構(gòu)造函數(shù)可知， ScheduledThreadPool 的核心線程數(shù)量是固定的，由傳入的 corePoolSize 參數(shù)決定，非核心線程數(shù)量可以無(wú)限大。非核心線程閑置回收的超時(shí)時(shí)間為 10秒（ DEFAULT_KEEPALIVE_MILLIS 的值為 10L ）。這類線程主要用于執(zhí)行定時(shí)任務(wù)或者具有周期性的重復(fù)任務(wù)。

只有一個(gè)核心線程，通過(guò) Executors 的 newsinglethreadexecutor 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法：

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(/* corePoolSize*/ 1, /* maximumPoolSize*/ 1,
                                /* keepAliveTime*/ 0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue()));
}

public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(/* corePoolSize*/ 1, /* maximumPoolSize*/ 1,
                                /* keepAliveTime*/ 0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue(),
                                threadFactory));
}

SingleThreadPool 由 代理類 FinalizableDelegatedExecutorService 創(chuàng)建。該線程池只有一個(gè)線程（核心線程），并且該線程池的任務(wù)隊(duì)列是無(wú)上限的，這就確保了所有的任務(wù)都在同一個(gè)線程中順序執(zhí)行。

注意，如果由于在執(zhí)行期間出現(xiàn)故障而導(dǎo)致該線程終止，那么如果需要執(zhí)行后續(xù)任務(wù)，則新線程將取而代之。

上面分別對(duì) Android 中常見(jiàn)的 4 種線程池進(jìn)行了簡(jiǎn)單的介紹，除了這 4 種系統(tǒng)提供的線程池外，我們?cè)谑褂玫倪^(guò)程中，也可以根據(jù)需要直接通過(guò) ThreadPoolExecutor 的構(gòu)造函數(shù)來(lái)靈活的配置線程池。那么，上述的 4 種線程池，其區(qū)別在哪呢？了解其區(qū)別有助于我們?nèi)ミx擇更為合適的線程池或者直接通過(guò) ThreadPoolExecutor 來(lái)配置更靈活的線程池。

FixedThreadPool 線程固定，且不會(huì)被回收，能夠更快的響應(yīng)外界請(qǐng)求。

CachedThreadPool 只有非核心線程，且線程數(shù)相當(dāng)于無(wú)限大，任何任務(wù)都會(huì)被立即執(zhí)行。比較適合執(zhí)行大量的耗時(shí)較少的任務(wù)。

ScheduledThreadPool 主要用于執(zhí)行定時(shí)任務(wù)或者具有周期性的重復(fù)任務(wù)。

SingleThreadPool 只有一個(gè)核心線程，確保所有任務(wù)都在同一線程中按順序完成。因此不需要處理線程同步的問(wèn)題。

《Android藝術(shù)開(kāi)發(fā)探索》，電子書(shū)下載

Android 官方文檔