亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

Android中創(chuàng)建多線程管理器實例

 更新時間:2014年06月26日 09:22:17   作者:冰凍魚  
這篇文章主要介紹了Android中創(chuàng)建多線程管理器實例,著重講解需要做的哪些事情,每一步都配有代碼例子,需要的朋友可以參考下

如果你要反復執(zhí)行一個任務(wù),用不同的數(shù)據(jù)集(參數(shù)不同),但一次只要一個執(zhí)行(任務(wù)是單線程的),IntentService符合你的需求。當需要在資源可用時自動執(zhí)行任務(wù),或允許多任務(wù)同時執(zhí)行,你需要一個線程管理器管理你的線程。ThreadPoolExecutor,會維護一個隊列,當它的線程池有空時,從隊列里取任務(wù),并執(zhí)行。要運行任務(wù),你要做的就是把它加到隊列里。

線程池可以并聯(lián)運行一個任務(wù)的多個實例,所以你要保存代碼線程安全。能被多線程訪問的變量需要同步塊.更多信息,見Processes and Threads(http://developer.android.com/guide/components/processes-and-threads.html)

定義線程池類

在它自己類中實例ThreadPoolExecutor.在類里,如下操作:

為線程池使用static變量

你可能在app里只需要一個單例的線程池,這是為了統(tǒng)一控制限制CPU或網(wǎng)絡(luò)資源。如果你有不同的Runnable類型,你可能想要每種類型都有各自的線程池,但這些都可以放到一個單一的實例里。比如,你可以把它聲明成全局變量:

復制代碼 代碼如下:

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

使用private構(gòu)造方法

把構(gòu)造方法聲明成private,可以確保單例,這意味著你不需要在同步代碼塊里封裝類訪問。

復制代碼 代碼如下:

 public class PhotoManager {
        ...
        /**
         * 構(gòu)建用來下載和decode圖片的工作隊列和線程池,因為構(gòu)造方法標記為private,
         * 對其他類不可訪問(甚至同包下的類)
         */
        private PhotoManager() {
            ...
        }

調(diào)用線程池類里的方法來開始任務(wù)

線程池類里定義一個方法,用來添加任務(wù)到線程池隊列,如:

復制代碼 代碼如下:

public class PhotoManager {
    ...
    // 供PhotoView調(diào)用獲取圖片
    static public PhotoTask startDownload(
        PhotoView imageView,
        boolean cacheFlag) {
        ...
        // 添加一個任務(wù)到線程池
        sInstance.
                mDownloadThreadPool.
                execute(downloadTask.getHTTPDownloadRunnable());
        ...
    }

實例化一個UI線程的Handler.

Handler用于與UI線程通訊,大多數(shù)UI控件只允許在UI線程修改。

復制代碼 代碼如下:

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ù)

一旦你有了全部類結(jié)構(gòu),你就可以開始定義線程池。實例化一個線程池對象,你需要下面的值:
初始池大小,最大池大小。
線程池的線程數(shù)量主要依賴于設(shè)備的CPU核心數(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è)備的物理cpu內(nèi)核數(shù)量;某些設(shè)備CPU會根據(jù)系統(tǒng)負載自動禁用部分內(nèi)核,對于這些設(shè)備,availableProcessors()返回的是當前活躍的內(nèi)核數(shù)量。

保持活躍時間和時間單位

一個進程在關(guān)閉前,保持空閑狀態(tài)的時間(可以復用進程)。時間單位在TimeUnit里

任務(wù)隊列

ThreadPoolExecutor的列隊保存Runnable對象。在線程中執(zhí)行代碼,線程池管理器會從一個FIFO隊列里取出一個Runnable對象,附加到線程里。隊列實現(xiàn)BlockingQueue接口,在創(chuàng)建線程池時提供。你可以從現(xiàn)有實現(xiàn)中選一個,適應(yīng)你的需求,參見ThreadPoolExecutor。下面是使用LinkedBlockingQueue的例子:

復制代碼 代碼如下:

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)建線程池

調(diào)用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);
    }

相關(guān)文章

最新評論