如果你想在一個數(shù)據(jù)集中重復執(zhí)行一個任務，而且你只需要一個執(zhí)行運行一次。這時，使用一個IntentService將能滿足你的需求。為了在資源可用的的時候自動執(zhí)行任務，或者允許不同的任務同時執(zhí)行（或前后兩者），你需要提供一個管理線程的集合。為了做這個管理線程的集合，使用一個ThreadPoolExecutor實例，當一個線程在它的線程池中變得不受約束時，它會運行隊列中的一個任務。為了能執(zhí)行這個任務，你所需要做的就是把它加入到這個隊列。

一個線程池能運行多個并行的任務實例，因此你要能保證你的代碼是線程安全的，從而你需要給會被多個線程訪問的變量附上同步代碼塊(synchronized block)。當一個線程在對一個變量進行寫操作時，通過這個方法將能阻止另一個線程對該變量進行讀取操作。典型的，這種情況會發(fā)生在靜態(tài)變量上，但同樣它也能突然發(fā)生在任意一個只實例化一次。為了學到更多的相關知識，你可以閱讀進程與線程這一API指南。

定義線程池類

在自己的類中實例化ThreadPoolExecutor類。在這個類里需要做以下事：

1. 為線程池使用靜態(tài)變量

為了有一個單一控制點用來限制CPU或涉及網(wǎng)絡資源的Runnable類型，你可能需要有一個能管理所有線程的線程池，且每個線程都會是單個實例。比如，你可以把這個作為一部分添加到你的全局變量的聲明中去：

public class PhotoManager {
    ...
    static  {
        ...
        // Creates a single static instance of PhotoManager
        sInstance = new PhotoManager();
    }
    ...

2. 使用私有構造方法

讓構造方法私有從而保證這是一個單例，這意味著你不需要在同步代碼塊(synchronized block)中額外訪問這個類：

public class PhotoManager {
    ...
    /**
     * Constructs the work queues and thread pools used to download
     * and decode images. Because the constructor is marked private,
     * it's unavailable to other classes, even in the same package.
     */
    private PhotoManager() {
    ...
    }

3.通過調用線程池類里的方法開啟你的任務

在線程池類中定義一個能添加任務到線程池隊列的方法。例如：

public class PhotoManager {
    ...
    // Called by the PhotoView to get a photo
    static public PhotoTask startDownload(
        PhotoView imageView,
        boolean cacheFlag) {
        ...
        // Adds a download task to the thread pool for execution
        sInstance.
                mDownloadThreadPool.
                execute(downloadTask.getHTTPDownloadRunnable());
        ...
    }

4. 在構造方法中實例化一個Handler，且將它附加到你APP的UI線程。

一個Handler允許你的APP安全地調用UI對象（例如 View對象）的方法。大多數(shù)UI對象只能從UI線程安全的代碼中被修改。這個方法將會在與UI線程進行通信(Communicate with the UI Thread)這一課中進行詳細的描述。例如：

private PhotoManager() {
    ...
        // Defines a Handler object that's attached to the UI thread
        mHandler = new Handler(Looper.getMainLooper()) {
            /*
             * handleMessage() defines the operations to perform when
             * the Handler receives a new Message to process.
             */
            @Override
            public void handleMessage(Message inputMessage) {
                ...
            }
        ...
        }
    }

確定線程池的參數(shù)

一旦有了整體的類結構,你可以開始定義線程池了。為了初始化一個ThreadPoolExecutor對象，你需要提供以下數(shù)值：

1. 線程池的初始化大小和最大的大小

這個是指最初分配給線程池的線程數(shù)量，以及線程池中允許的最大線程數(shù)量。在線程池中擁有的線程數(shù)量主要取決于你的設備的CPU內核數(shù)。

這個數(shù)字可以從系統(tǒng)環(huán)境中獲得：

public class PhotoManager {
...
    /*
     * Gets the number of available cores
     * (not always the same as the maximum number of cores)
     */
    private static int NUMBER_OF_CORES =
            Runtime.getRuntime().availableProcessors();
}

這個數(shù)字可能并不反映設備的物理核心數(shù)量，因為一些設備根據(jù)系統(tǒng)負載關閉了一個或多個CPU內核，對于這樣的設備，availableProcessors()方法返回的是處于活動狀態(tài)的內核數(shù)量，可能少于設備的實際內核總數(shù)。

2.線程保持活動狀態(tài)的持續(xù)時間和時間單位

這個是指線程被關閉前保持空閑狀態(tài)的持續(xù)時間。這個持續(xù)時間通過時間單位值進行解譯，是TimeUnit()中定義的常量之一。

3.一個任務隊列

這個傳入的隊列由ThreadPoolExecutor獲取的Runnable對象組成。為了執(zhí)行一個線程中的代碼，一個線程池管理者從先進先出的隊列中取出一個Runnable對象且把它附加到一個線程。當你創(chuàng)建線程池時需要提供一個隊列對象，這個隊列對象類必須實現(xiàn)BlockingQueue接口。為了滿足你的APP的需求，你可以選擇一個Android SDK中已經(jīng)存在的隊列實現(xiàn)類。為了學習更多相關的知識，你可以看一下ThreadPoolExecutor類的概述。下面是一個使用LinkedBlockingQueue實現(xiàn)的例子：

public class PhotoManager {
    ...
    private PhotoManager() {
        ...
        // A queue of Runnables
        private final BlockingQueue<Runnable> mDecodeWorkQueue;
        ...
        // Instantiates the queue of Runnables as a LinkedBlockingQueue
        mDecodeWorkQueue = new LinkedBlockingQueue<Runnable>();
        ...
    }
    ...
}

創(chuàng)建一個線程池

為了創(chuàng)建一個線程池，可以通過調用ThreadPoolExecutor()構造方法初始化一個線程池管理者對象，這樣就能創(chuàng)建和管理一組可約束的線程了。如果線程池的初始化大小和最大大小相同，ThreadPoolExecutor在實例化的時候就會創(chuàng)建所有的線程對象。例如：

private PhotoManager() {
        ...
        // Sets the amount of time an idle thread waits before terminating
        private static final int KEEP_ALIVE_TIME = 1;
        // Sets the Time Unit to seconds
        private static final TimeUnit KEEP_ALIVE_TIME_UNIT = TimeUnit.SECONDS;
        // Creates a thread pool manager
        mDecodeThreadPool = new ThreadPoolExecutor(
                NUMBER_OF_CORES,       // Initial pool size
                NUMBER_OF_CORES,       // Max pool size
                KEEP_ALIVE_TIME,
                KEEP_ALIVE_TIME_UNIT,
                mDecodeWorkQueue);
    }

上一篇：建立一個Notification下一篇：更新你的Security Provider來對抗SSL漏洞利用