最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

在Android線程池里運(yùn)行代碼任務(wù)實(shí)例

 更新時(shí)間:2014年06月26日 09:14:26   作者:冰凍魚(yú)  
這篇文章主要介紹了在Android線程池里運(yùn)行代碼任務(wù)實(shí)例,同時(shí)介紹了線程池中停止任務(wù)的方法,需要的朋友可以參考下

本節(jié)展示如何在線程池里執(zhí)行任務(wù)。流程是,添加一個(gè)任務(wù)到線程池的工作隊(duì)列,當(dāng)有線程可用時(shí)(執(zhí)行完其他任務(wù),空閑,或者還沒(méi)執(zhí)行任務(wù)),ThreadPoolExecutor會(huì)從隊(duì)列里取任務(wù),并在線程里運(yùn)行。
本課同時(shí)向你展示了如何停止正在運(yùn)行的任務(wù)。

在線程池里的線程上執(zhí)行任務(wù)

在ThreadPoolExecutor.execute()里傳入 Runnable對(duì)象啟動(dòng)任務(wù)。這個(gè)方法會(huì)把任務(wù)添加到線程池工作隊(duì)列。當(dāng)有空閑線程時(shí),管理器會(huì)取出等待最久的任務(wù),在線程上運(yùn)行。

復(fù)制代碼 代碼如下:

public class PhotoManager {
    public void handleState(PhotoTask photoTask, int state) {
        switch (state) {
            // The task finished downloading the image
            case DOWNLOAD_COMPLETE:
            // Decodes the image
                mDecodeThreadPool.execute(
                        photoTask.getPhotoDecodeRunnable());
            ...
        }
        ...
    }
    ...
}

當(dāng)ThreadPoolExecutor啟動(dòng)Runnable時(shí),會(huì)自動(dòng)調(diào)用run()方法。

中斷正在運(yùn)行的代碼

要停止任務(wù),你需要中斷任務(wù)的進(jìn)程。你需要在創(chuàng)建任務(wù)的時(shí)候,保存一個(gè)當(dāng)前線程的handle.
如:

復(fù)制代碼 代碼如下:

class PhotoDecodeRunnable implements Runnable {
    // Defines the code to run for this task
    public void run() {
        /*
         * Stores the current Thread in the
         * object that contains PhotoDecodeRunnable
         */
        mPhotoTask.setImageDecodeThread(Thread.currentThread());
        ...
    }
    ...
}

要中斷線程,調(diào)用Thread.interrupt()就可以了。提示:線程對(duì)象是系統(tǒng)控制的,可以在你的app進(jìn)程外被編輯。因?yàn)檫@個(gè)原因,你需要在中斷它前加訪問(wèn)鎖,放到一個(gè)同步塊里:

復(fù)制代碼 代碼如下:

public class PhotoManager {
    public static void cancelAll() {
        /*
         * Creates an array of Runnables that's the same size as the
         * thread pool work queue
         */
        Runnable[] runnableArray = new Runnable[mDecodeWorkQueue.size()];
        // Populates the array with the Runnables in the queue
        mDecodeWorkQueue.toArray(runnableArray);
        // Stores the array length in order to iterate over the array
        int len = runnableArray.length;
        /*
         * Iterates over the array of Runnables and interrupts each one's Thread.
         */
        synchronized (sInstance) {
            // Iterates over the array of tasks
            for (int runnableIndex = 0; runnableIndex < len; runnableIndex++) {
                // Gets the current thread
                Thread thread = runnableArray[taskArrayIndex].mThread;
                // if the Thread exists, post an interrupt to it
                if (null != thread) {
                    thread.interrupt();
                }
            }
        }
    }
    ...
}

在大多數(shù)案例里,Thread.interrupt()會(huì)馬上停止線程??墒牵粫?huì)停止在等待的線程,但不會(huì)中斷cpu或network-intensive任務(wù)。為了避免系統(tǒng)變慢,你應(yīng)該在開(kāi)始嘗試操作前測(cè)試等待中斷的請(qǐng)求。

復(fù)制代碼 代碼如下:

/*
 * Before continuing, checks to see that the Thread hasn't
 * been interrupted
 */
if (Thread.interrupted()) {
    return;
}
...
// Decodes a byte array into a Bitmap (CPU-intensive)
BitmapFactory.decodeByteArray(
        imageBuffer, 0, imageBuffer.length, bitmapOptions);
...

相關(guān)文章

最新評(píng)論

高平市| 江孜县| 永登县| 正蓝旗| 同仁县| 平潭县| 和林格尔县| 原平市| 行唐县| 白水县| 钟祥市| 曲麻莱县| 隆化县| 沙田区| 边坝县| 樟树市| 乐山市| 漳平市| 陇西县| 古浪县| 周口市| 隆昌县| 威远县| 永平县| 泰宁县| 杭锦旗| 安庆市| 章丘市| 古丈县| 湘潭市| 连江县| 辽源市| 杭锦后旗| 五原县| 广安市| 云浮市| 任丘市| 酉阳| 通化市| 七台河市| 广水市|