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

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

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

本節(jié)展示如何在線程池里執(zhí)行任務(wù)。流程是,添加一個(gè)任務(wù)到線程池的工作隊(duì)列,當(dāng)有線程可用時(shí)(執(zhí)行完其他任務(wù),空閑,或者還沒執(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è)原因,你需要在中斷它前加訪問鎖,放到一個(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)該在開始嘗試操作前測試等待中斷的請(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)論

河南省| 虎林市| 大埔县| 齐河县| 永嘉县| 上饶市| 神农架林区| 关岭| 崇明县| 黄平县| 志丹县| 临沧市| 北辰区| 安西县| 河东区| 延川县| 翁源县| 辉县市| 突泉县| 察哈| 雷州市| 吴江市| 夏河县| 广南县| 凤阳县| 肃南| 郴州市| 望城县| 万全县| 腾冲县| 龙井市| 中西区| 泰来县| 田东县| 青岛市| 新和县| 辽阳县| 观塘区| 奉化市| 舞钢市| 安庆市|