快捷導(dǎo)航

在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);

...

您可能感興趣的文章: