關(guān)于Android 3.0以后AsyncTask默認(rèn)單一線程的分析

時間：2014-11-04 22:24:57

關(guān)鍵字： Android 線程 ASYNCTASK BSP

手機(jī)看文章

掃描二維碼
隨時隨地手機(jī)看文章

[導(dǎo)讀] 在Android里需要大量后臺操作的情況下，經(jīng)常會使用到AsyncTask這個類，比如說加載網(wǎng)絡(luò)圖片，訪問服務(wù)器的接口，一般的使用情境就是實例化一個AsyncTask的對象mTask，復(fù)寫A

在Android里需要大量后臺操作的情況下，經(jīng)常會使用到AsyncTask這個類，比如說加載網(wǎng)絡(luò)圖片，訪問服務(wù)器的接口，一般的使用情境就是實例化一個AsyncTask的對象mTask，復(fù)寫AsyncTask的抽象方法doinBackgroud等等，最后執(zhí)行task.execute(params)，然后就可以在UI線程上方便的取得后臺線程的執(zhí)行結(jié)果;

AsyncTask執(zhí)行中最終觸發(fā)的是把任務(wù)交給線池THREAD_POOL_EXECUTOR來執(zhí)行，提交的任務(wù)并行的在線程池中運行，但這些規(guī)則在3.0之后發(fā)生了變化，3.0之后提交的任務(wù)是串行運行的，執(zhí)行完一個任務(wù)才執(zhí)行下一個!

先看看3.0以前的代碼;

1

2

3

private static final int CORE_POOL_SIZE = 5;
private static final int MAXIMUM_POOL_SIZE = 128;
private static final int KEEP_ALIVE = 10;

1

1

1	`public` `static` `final` `Executor THREAD_POOL_EXECUTOR =` `new` `ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);`

3.0以前線程池里核心線程有5個，同時存在的線程數(shù)最大不能超過128個，線程池里的線程都是并行運行的;

但是在3.0之后，直接調(diào)用execute(params)觸發(fā)的是sDefaultExecutor的execute(runnable)方法，而不是原來的THREAD_POOL_EXECUTOR

1

2

3

private static final int CORE_POOL_SIZE = CPU_COUNT + 1;
private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;
private static final int KEEP_ALIVE = 1;

1

2

3

public static void execute(Runnable runnable) {
        sDefaultExecutor.execute(runnable);
    }

看看這個sDefaultExecutor與原來的THREAD_POOL_EXECUTOR線程池有什么差別，sDefaultExecutor實際上是指向SerialExecutor的一個實例，從名字上看是一個順序執(zhí)行的executor;

public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;
 
 private static class SerialExecutor implements Executor {
        final ArrayDeque<runnable> mTasks = new ArrayDeque<runnable>();
        Runnable mActive;
 
        public synchronized void execute(final Runnable r) {
            mTasks.offer(new Runnable() {
                public void run() {
                    try {
                        r.run();
                    } finally {
                        scheduleNext();
                    }
                }
            });
            if (mActive == null) {
                scheduleNext();
            }
        }
 
        protected synchronized void scheduleNext() {
            if ((mActive = mTasks.poll()) != null) {
                THREAD_POOL_EXECUTOR.execute(mActive);
            }
        }
    }</runnable></runnable>

分析SerialExecutor，當(dāng)提交一個任務(wù)，執(zhí)行一次execute()，向mTasks添加一個runnable，此時mActive為null，接著會執(zhí)行scheduleNext()，將mActive指向剛剛添加的runbale，并提交到THREAD_POOL_EXECUTOR中執(zhí)行，接著就線程池中就會執(zhí)行下面這段代碼;

1

2

3

4

5

try {
                        r.run();
                    } finally {
                        scheduleNext();
                    }

當(dāng)asyncTask提交大量的任務(wù)時，會重復(fù)之前的流程，任務(wù)都添加至mTasks中了，提交第一個任務(wù)之后，mActive便不再為Null了，之后的任務(wù)如果要被執(zhí)行就必需等到前一個任務(wù)run方法跑完，也就是try{ }語句塊中的run(),前一個任務(wù)執(zhí)行完后，才會調(diào)用finally

后面的scheduleNext()從mTasks中取出下一個任務(wù)來執(zhí)行;

分析完上面的代碼后，現(xiàn)在對于3.0以后AsyncTask默認(rèn)情況下同時只存在一個線程順序執(zhí)行的原理就了解清楚了;

如果想要提交的任務(wù)在能并行執(zhí)行呢?這在網(wǎng)絡(luò)圖片顯示中還是比較有用的;

AsyncTask也為我們提供了另外一種啟動方法