上一節(jié)我們知道肺魁，想要啟動(dòng)一個(gè)AsyncTask狐肢，首先需要?jiǎng)?chuàng)建一個(gè)AsyncTask對(duì)象然后調(diào)用execute方法。例如：
new DownloadFilesTask().execute();
DownloadFilesTask繼承自AsyncTask需要指定3個(gè)泛型參數(shù)：
private class DownloadFilesTask extends AsyncTask<URL, Integer, Long> {
protected void onPreExecute() {
super.onPreExecute();
}
protected Long doInBackground(URL... urls) {
int count = urls.length;
long totalSize = 0;
for (int i = 0; i < count; i++) {
totalSize += Downloader.downloadFile(urls[i]);
publishProgress((int) ((i / (float) count) * 100));
// Escape early if cancel() is called
if (isCancelled()) break;
}
return totalSize;
}
protected void onProgressUpdate(Integer... progress) {
setProgressPercent(progress[0]);
}
protected void onPostExecute(Long result) {
showDialog("Downloaded " + result + " bytes");
}
}
一啃沪、AsyncTask構(gòu)造函數(shù)
首先先從AsyncTask的構(gòu)造函數(shù)說起：
/**AsyncTask的構(gòu)造函數(shù)源碼片段**/
public AsyncTask() {
mWorker = new WorkerRunnable<Params, Result>() {
public Result call() throws Exception {
mTaskInvoked.set(true);
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
Result result = doInBackground(mParams);
Binder.flushPendingCommands();
return postResult(result);
}
};
mFuture = new FutureTask<Result>(mWorker) {
@Override
protected void done() {
try {
postResultIfNotInvoked(get());
} catch (InterruptedException e) {
android.util.Log.w(LOG_TAG, e);
} catch (ExecutionException e) {
...
e.getCause());
} catch (CancellationException e) {
postResultIfNotInvoked(null);
}
}
};
}
在AsyncTask構(gòu)造函數(shù)中初始化了兩個(gè)對(duì)象：WorkerRunnable和FutureTask枪孩，分別賦值為mWorker、mFuture甚侣。這兩個(gè)對(duì)象初始化都實(shí)現(xiàn)了兩個(gè)回調(diào)方法明吩，當(dāng)用戶執(zhí)行了execute方法的時(shí)候在特定情況下會(huì)觸發(fā)這兩個(gè)對(duì)象的回調(diào)方法，下面我們就開始詳細(xì)分析這兩個(gè)對(duì)象渺绒。
結(jié)論：doInBackground是在WorkerRunnable的call方法中被回調(diào)執(zhí)行的
WorkerRunnable【mWorker】
由于WorkerRunnable實(shí)現(xiàn)了Callable接口贺喝，所以在AsyncTask的構(gòu)造函數(shù)中實(shí)例化WorkerRunnable時(shí)，必須實(shí)現(xiàn)call()方法宗兼。其中還需要指定泛型參數(shù)Params和Result躏鱼。這樣在回調(diào)了call方法之后，就能返回Result殷绍。
/** WorkerRunable類**/
private static abstrat class WorkerRunable<Params, Result> implements Callable<Result>
{
Params[] mParams;
}
/** Callable接口**/
public interface Callable<V>
{
V call() throws Exception;
}
現(xiàn)在我們暫時(shí)只需要知道當(dāng)執(zhí)行execute的時(shí)候會(huì)回調(diào)WorkerRunnable的call方法染苛。
FutureTask【mFuture】
從上面的AsyncTask的構(gòu)造函數(shù)源碼中可以看到，在構(gòu)造FutureTask對(duì)象初始化時(shí)主到，mWorker是作為參數(shù)傳遞進(jìn)來的茶行。從FutureTask的構(gòu)造函數(shù)也看出來了FutureTask需要一個(gè)Callable對(duì)象。
/** FutureTask的構(gòu)造函數(shù)**/
public FutureTask(Callable<V> callable) {
if (callable == null)
throw new NullPointerException();
this.callable = callable;
this.state = NEW; // ensure visibility of callable
}
【在這里不禁可以提前猜測(cè)出一個(gè)信息了登钥，既然FutureTask把WorkerRunnable傳遞進(jìn)來了畔师，那WorkerRunnable的回調(diào)方法call肯定是在FutureTask中調(diào)用的】
來看看FutureTask這個(gè)類：
可以看出，F(xiàn)utureTask是實(shí)現(xiàn)了RunnableFuture接口牧牢，而這個(gè)接口繼承了Runnable看锉、以及Future。
通過上面兩個(gè)類塔鳍，發(fā)現(xiàn)其實(shí)FutureTask中的get方法實(shí)現(xiàn)了Runnable的阻塞和返回執(zhí)行完畢的數(shù)據(jù)(泛型V)伯铣。
我們?cè)賮砜碏utureTask的run方法，豁然開朗轮纫，原來WorkerRunnable中的回調(diào)方法call果然是在這里調(diào)用的腔寡。
結(jié)論：WorkerRunnable中的回調(diào)方法call()是在執(zhí)行FutureTask的run方法后回調(diào)的。當(dāng)WorkerRunnable的call方法執(zhí)行完畢后將返回?cái)?shù)據(jù)給FutureTask掌唾。
疑問：那么放前，F(xiàn)utureTask的run方法又是被誰(shuí)調(diào)用的呢？
二郑兴、execute()方法
很顯然犀斋，F(xiàn)utureTask的run方法肯定需要AsyncTask執(zhí)行execute方法后才會(huì)執(zhí)行。
private static volatile Executor sDefaultExecutor = SERIAL_EXECUTOR;
public static final Executor SERIAL_EXECUTOR = new SerialExecutor();
/** AsyncTask類的execute方法**/
public final AsyncTask<Params, Progress, Result> execute(Params... params) {
return executeOnExecutor(sDefaultExecutor, params);
}
當(dāng)執(zhí)行execute方法時(shí)情连，其實(shí)是調(diào)用的executeOnExecutor方法叽粹。這里傳遞了兩個(gè)參數(shù)，一個(gè)是sDefaultExecutor，一個(gè)是params虫几。從上面的源碼可以看出锤灿，sDefaultExecutor其實(shí)是一個(gè)SerialExecutor對(duì)象。params其實(shí)最終會(huì)賦給doInBackground方法辆脸，就是用戶實(shí)現(xiàn)回調(diào)的方法但校，這個(gè)后面會(huì)看到。
executeOnExecutor
我們現(xiàn)在先來看executeOnExecutor方法啡氢。
/** AsyncTask類的executeOnExecutor方法**/
public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
Params... params) {
...
mStatus = Status.RUNNING;
onPreExecute();
mWorker.mParams = params;
exec.execute(mFuture);
return this;
}
看到木有状囱？在這個(gè)方法中，最先先執(zhí)行了onPreExecute()方法倘是，此時(shí)便會(huì)回調(diào)到用戶自定義AsyncTask的實(shí)現(xiàn)方法onPreExecute【看本文最頂部第一個(gè)例子的代碼】亭枷。onPreExecute可以用來做一些后臺(tái)任務(wù)執(zhí)行之前的準(zhǔn)備工作。
通過上面的代碼可以看出搀崭，執(zhí)行到exec.execute(mFuture)這里時(shí)傳遞進(jìn)去了一個(gè)mFuture叨粘，這個(gè)mFuture就是之前AsyncTask構(gòu)造初始化賦值的FutureTask。exec其實(shí)就是之前執(zhí)行AsyncTask.execute()方法時(shí)傳遞進(jìn)來的參數(shù)sDefaultExecutor瘤睹，剛剛也說了這個(gè)sDefaultExecutor其實(shí)就是SerialExecutor對(duì)象升敲。嗯，exec就是SerialExecutor對(duì)象轰传。
SerialExecutor
我們可以看到驴党，之前exec.execute(mFuture)執(zhí)行時(shí)，SerialExecutor將FutureTask作為參數(shù)執(zhí)行execute方法获茬。在SerialExecutor的execute方法中鼻弧，這里通過一個(gè)任務(wù)隊(duì)列mTasks把FutureTask插入進(jìn)了隊(duì)列中，執(zhí)行r.run锦茁，其實(shí)就是執(zhí)行FutureTask的run方法，因?yàn)閭鬟f進(jìn)來的r參數(shù)就是mFuture叉存。
/** AsyncTask對(duì)象中的SerialExecutor成員變量【內(nèi)部類】 **/
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);
}
}
}
結(jié)論：FutureTask的run方法是在SerialExecutor的execute方法中執(zhí)行的码俩。
其實(shí)在這里，SerialExecutor實(shí)現(xiàn)了一個(gè)任務(wù)的排隊(duì)算法歼捏。當(dāng)一個(gè)AsyncTask任務(wù)開始execute時(shí)稿存，首先執(zhí)行FutureTask的run方法，然后finally執(zhí)行scheduleNext方法瞳秽，然后執(zhí)行THREAD_POOL_EXECUTOR的execute方法瓣履。繼續(xù)往下，如果mActive為空练俐，就會(huì)繼續(xù)調(diào)用scheduleNext方法執(zhí)行下一個(gè)AsyncTask任務(wù)袖迎，說白了就是當(dāng)mActive這個(gè)Runnable執(zhí)行完畢之后，才會(huì)繼續(xù)調(diào)用 THREAD_POOL_EXECUTOR.execute(mActive)。這樣SerialExecutor便實(shí)現(xiàn)了串行的任務(wù)隊(duì)列燕锥。
結(jié)論：SerialExecutor只是實(shí)現(xiàn)任務(wù)隊(duì)列辜贵，真正執(zhí)行線程池的是THREAD_POOL_EXECUTOR。
前面我們已經(jīng)知道归形，F(xiàn)utureTask的run方法在SerialExecutor的execute方法中執(zhí)行了托慨，然后由 mTasks.offer 封裝成一個(gè)Runnable(mActive)給THREAD_POOL_EXECUTOR。
public static final Executor THREAD_POOL_EXECUTOR
= new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);
到這里暇榴，F(xiàn)utureTask的run方法要開始回調(diào)WorkerRunable的call方法了厚棵。是不是已經(jīng)開始暈了，2333蔼紧。撐住 !!!! 接下來我們還要看WorkerRunable的回調(diào)call方法：
oh my god ! 終于開始回調(diào)doInBackground方法了婆硬。看到現(xiàn)在已經(jīng)很明白了歉井，doInBackground的執(zhí)行不是在主線程中柿祈。
mWorker = new WorkerRunnable<Params, Result>() {
public Result call() throws Exception {
mTaskInvoked.set(true);
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
Result result = doInBackground(mParams);
Binder.flushPendingCommands();
return postResult(result);
}
};
doInBackground(mParams)執(zhí)行完后返回result，接著再繼續(xù)執(zhí)行postResult方法哩至，并將返回的result作為參數(shù)傳遞進(jìn)去□锖浚現(xiàn)在我們來看postResult方法，當(dāng)當(dāng)當(dāng)當(dāng)菩貌，Handler開始登場(chǎng)了卢佣。這里在執(zhí)行完doInBackground后直接發(fā)送了一個(gè)消息給Handler，那么這個(gè)Handler又是哪個(gè)呢箭阶？
private Result postResult(Result result) {
Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,
new AsyncTaskResult<Result>(this, result));
message.sendToTarget();
return result;
}
繼續(xù)看getHandler方法：
private static Handler getHandler() {
synchronized (AsyncTask.class) {
if (sHandler == null) {
sHandler = new InternalHandler();
}
return sHandler;
}
}
private static class InternalHandler extends Handler {
public InternalHandler() {
super(Looper.getMainLooper());
}
@Override
public void handleMessage(Message msg) {
AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;
switch (msg.what) {
case MESSAGE_POST_RESULT:
// There is only one result
result.mTask.finish(result.mData[0]);
break;
case MESSAGE_POST_PROGRESS:
result.mTask.onProgressUpdate(result.mData);
break;
}
}
}
之前執(zhí)行postResult的時(shí)候虚茶，obtainMessage傳遞的參數(shù)是：MESSAGE_POST_RESULT和AsyncTaskResult<Result>(this, result))，然后message.sendToTarget()開始發(fā)消息仇参，并在InternalHandler的handleMessage中開始處理消息嘹叫。
結(jié)論：doInBackground執(zhí)行完后立即發(fā)送了一個(gè)消息給InternalHandler
private void finish(Result result) {
if (isCancelled()) {
onCancelled(result);
} else {
onPostExecute(result);
}
mStatus = Status.FINISHED;
}
private static class AsyncTaskResult<Data> {
final AsyncTask mTask;
final Data[] mData;
AsyncTaskResult(AsyncTask task, Data... data) {
mTask = task;
mData = data;
}
}
由于傳遞的是MESSAGE_POST_RESULT，所以執(zhí)行mTask.finish方法诈乒。這個(gè)時(shí)候doInBackground已經(jīng)執(zhí)行完了并返回了result罩扇，便開始執(zhí)行onPostExecute方法，并將result傳遞進(jìn)去怕磨。因?yàn)镮nternalHandler是通過Looper.getMainLooper()獲得的喂饥，所以是在主線程，所以最后onPostExecute方法便又回到了主線程執(zhí)行肠鲫。這個(gè)時(shí)候onPostExecute就可以拿到doInBackground異步執(zhí)行返回的result员帮，直接更新UI。
