概述
Android 已封裝好的輕量級異步類睹酌。內置一個線程池用于異步任務,另一個線程池用于排隊(實際不是線程池)纠炮。一個默認綁定mainLooper的Handler用于UI線程巢株。
使用
- public abstract class AsyncTask<Params, Progress, Result> Params 傳參的類型,Progress 進度的類型腾夯,Result 返回結果的類型
- execute(Params... params):執(zhí)行一個異步任務,需要我們在代碼中調用此方法蔬充,觸發(fā)異步任務的執(zhí)行蝶俱。UI線程調用。
- onPreExecute():在execute(Params... params)被調用后立即執(zhí)行饥漫,一般用來在執(zhí)行后臺任務前對UI做一些準備工作榨呆。
- doInBackground(Params... params) 關鍵方法,用于執(zhí)行較為費時的操作庸队,在onPreExecute()完成后立即執(zhí)行积蜻,此方法將接收輸入?yún)?shù)和返回計算結果闯割。doInBackground方法接收的參數(shù)就是execute()中傳入的參數(shù):另外在執(zhí)行過程中可以調用publishProgress(Progress... values)來更新進度信息。
- onProgressUpdate(Progress... values)竿拆,如果調用publishProgress(Progress... values)時宙拉,此方法被執(zhí)行,直接將進度信息更新到UI組件上丙笋。否則不執(zhí)行
- onPostExecute(Result result)谢澈,當后臺操作結束時,此方法將會被調用御板,計算結果(就是doInBackground方法返回的結果)將做為參數(shù)傳遞到此方法中锥忿,直接將結果顯示到UI組件上。
- cancel(boolean)方法怠肋,可以取消任務敬鬓。這個方法會產(chǎn)生的影響是:之后調用的iscancelled()會返回true。
源碼分析
static {
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, TimeUnit.SECONDS,
sPoolWorkQueue, sThreadFactory);
threadPoolExecutor.allowCoreThreadTimeOut(true);
THREAD_POOL_EXECUTOR = threadPoolExecutor;
}
THREAD_POOL_EXECUTOR 是真正用于異步任務的線程池笙各《ご穑可以看到它是靜態(tài)的,也就是每次new AsyncTask()都是用的同一個線程池杈抢。
public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
private static class SerialExecutor implements Executor {
final ArrayDeque<Runnable> mTasks = new ArrayDeque<Runnable>();//ArrayDeque依賴于可變數(shù)組來實現(xiàn)的雙端隊列数尿,可根據(jù)需求自動進行擴容。
Runnable mActive;//當前執(zhí)行的任務
public synchronized void execute(final Runnable r) {
mTasks.offer(new Runnable() {//offer向隊列中插入一個元素春感,并返回true,如果隊列已滿砌创,返回false(add在滿時報錯)
public void run() {
try {
r.run();
} finally {
scheduleNext();
}
}
});
if (mActive == null) {
scheduleNext();
}
}
protected synchronized void scheduleNext() {
if ((mActive = mTasks.poll()) != null) {//poll取出隊列頭部的元素,并從隊列中移除
THREAD_POOL_EXECUTOR.execute(mActive);
}
}
}
SERIAL_EXECUTOR 是實現(xiàn)了Executor 接口鲫懒,但內部操作是把Runnable 任務放入一個ArrayDeque(雙端隊列)嫩实。并且每執(zhí)行完一個取出下一個任務執(zhí)行。其實它不是線程池窥岩。
AsyncTask.execute()默認會調用到這個對象執(zhí)行,它會一個個的取出任務再用真正的線程池THREAD_POOL_EXECUTOR執(zhí)行甲献,由此可見,用一個AsyncTask對象執(zhí)行多個任務會是串行執(zhí)行的颂翼。那么如何讓它并行執(zhí)行呢晃洒?改為調用AsyncTask.executeOnExecuter(AsyncTask.THREAD_POOL_EXECUTOR,"")就可以了。
public AsyncTask(@Nullable Looper callbackLooper) {// 默認構造方法會走到這里
mHandler = callbackLooper == null || callbackLooper == Looper.getMainLooper()
? getMainHandler()// 一般是綁定mainLooper的內置的Handler類
: new Handler(callbackLooper);// 特殊情況
mWorker = new WorkerRunnable<Params, Result>() { // 繼承callable的類
public Result call() throws Exception {
mTaskInvoked.set(true);// 調用標識朦乏,F(xiàn)utureTask的done方法里調postResultIfNotInvoked會判斷
Result result = null;
try {
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);// 設置線程的優(yōu)先級
//noinspection unchecked
result = doInBackground(mParams);//這里調關鍵方法doInBackground球及,執(zhí)行耗時任務,并獲取結果
Binder.flushPendingCommands(); //將進程中未執(zhí)行的命令,一并送往CPU處理
} catch (Throwable tr) {
mCancelled.set(true);//如果運行異常,設置取消的標志
throw tr;
} finally {
postResult(result);//發(fā)送結果
}
return result;
}
};
//一個包裝任務的包裝類呻疹,與callable結合使用
mFuture = new FutureTask<Result>(mWorker) {
@Override
protected void done() {
try {//在執(zhí)行完任務做一道檢查,將沒被調用的Result也一并發(fā)出.這個方法根據(jù)上面的mTaskInvoked判斷
postResultIfNotInvoked(get());
} catch (InterruptedException e) {
android.util.Log.w(LOG_TAG, e);
} catch (ExecutionException e) {
throw new RuntimeException("An error occurred while executing doInBackground()",
e.getCause());
} catch (CancellationException e) {
postResultIfNotInvoked(null);//如果發(fā)生異常,則將結果滯null發(fā)出.
}
}
};
}
callable與runnable的區(qū)別是吃引,他的call方法有返回值。所以AsyncTask沒有用runnable而是用的